LogDog: Update protobufs, add support library.

common/logdog/protocol/log.pb.go

 // Code generated by protoc-gen-go.
 // source: log.proto
 // DO NOT EDIT!
 
 /*
 Package protocol is a generated protocol buffer package.
 
 It is generated from these files:
         log.proto
         butler.proto
@@ skipping 121 matching lines @@
         return ""
 }
 
 // *
 // An individual log entry.
 //
 // This contains the superset of transmissible log data. Its content fields
 // should be interpreted in the context of the log stream's content type.
 type LogEntry struct {
         //
-        // The stream time offset (in microseconds) for this entry (required).
+        // The stream time offset for this entry (required).
         //
         // This offset is added to the log stream's base "timestamp" to resolve the
         // timestamp for this specific LogEntry.
-        TimeOffsetUs *uint64 `protobuf:"varint,1,opt,name=time_offset_us" json:"time_offset_us,omitempty"`
+        TimeOffset *TimeOffset `protobuf:"bytes,1,opt,name=time_offset" json:"time_offset,omitempty"`
         //
         // The message index within the Prefix (required).
         //
         // This is value is unique to this LogEntry across the entire set of entries
         // sharing the stream's Prefix. It is used to designate unambiguous log
         // ordering.
-        PrefixIndex *uint64 `protobuf:"varint,2,opt,name=prefix_index" json:"prefix_index,omitempty"`
+        PrefixIndex *uint32 `protobuf:"varint,2,opt,name=prefix_index" json:"prefix_index,omitempty"`
         //
         // The message index within its Stream (required).
         //
         // This value is unique across all entries sharing the same Prefix and Stream
         // Name. It is used to designate unambiguous log ordering within the stream.
-        StreamIndex *uint64 `protobuf:"varint,3,opt,name=stream_index" json:"stream_index,omitempty"`
+        StreamIndex *uint32 `protobuf:"varint,3,opt,name=stream_index" json:"stream_index,omitempty"`
         //
         // (Text) Lines of log text.
         //
         // For text logs, each string represents a single log line. Newlines should
         // not be included.
-        Lines []string `protobuf:"bytes,4,rep,name=lines" json:"lines,omitempty"`
-        //
-        // (Data) Log binary data.
-        //
-        // For binary logs, each entry is a sequential chunk of log data. For
-        // datagram logs, each entry is an independent datagram.
-        Data             [][]byte `protobuf:"bytes,5,rep,name=data" json:"data,omitempty"`
-        XXX_unrecognized []byte   `json:"-"`
+        Lines            []string         `protobuf:"bytes,4,rep,name=lines" json:"lines,omitempty"`
+        Data             []*LogEntry_Data `protobuf:"bytes,5,rep,name=data" json:"data,omitempty"`
+        XXX_unrecognized []byte           `json:"-"`
 }
 
 func (m *LogEntry) Reset()         { *m = LogEntry{} }
 func (m *LogEntry) String() string { return proto.CompactTextString(m) }
 func (*LogEntry) ProtoMessage()    {}
 
-func (m *LogEntry) GetTimeOffsetUs() uint64 {
-        if m != nil && m.TimeOffsetUs != nil {
-                return *m.TimeOffsetUs
+func (m *LogEntry) GetTimeOffset() *TimeOffset {
+        if m != nil {
+                return m.TimeOffset
         }
-        return 0
+        return nil
 }
 
-func (m *LogEntry) GetPrefixIndex() uint64 {
+func (m *LogEntry) GetPrefixIndex() uint32 {
         if m != nil && m.PrefixIndex != nil {
                 return *m.PrefixIndex
         }
         return 0
 }
 
-func (m *LogEntry) GetStreamIndex() uint64 {
+func (m *LogEntry) GetStreamIndex() uint32 {
         if m != nil && m.StreamIndex != nil {
                 return *m.StreamIndex
         }
         return 0
 }
 
 func (m *LogEntry) GetLines() []string {
         if m != nil {
                 return m.Lines
         }
         return nil
 }
 
-func (m *LogEntry) GetData() [][]byte {
+func (m *LogEntry) GetData() []*LogEntry_Data {
         if m != nil {
                 return m.Data
         }
         return nil
 }
 
+//
+// (Data) Log binary data.
+//
+// For binary logs, each entry is a sequential chunk of log data. For
+// datagram logs, each entry is an independent datagram.
+type LogEntry_Data struct {
+        Value            []byte `protobuf:"bytes,1,opt,name=value" json:"value,omitempty"`
+        XXX_unrecognized []byte `json:"-"`
+}
+
+func (m *LogEntry_Data) Reset()         { *m = LogEntry_Data{} }
+func (m *LogEntry_Data) String() string { return proto.CompactTextString(m) }
+func (*LogEntry_Data) ProtoMessage()    {}
+
+func (m *LogEntry_Data) GetValue() []byte {
+        if m != nil {
+                return m.Value
+        }
+        return nil
+}
+
 // *
 // LogIndex is an index into an at-rest log storage.
 //
 // The log stream and log index are generated by the Archivist during archival.
 //
 // An archived log stream is a series of contiguous LogEntry frames. The index
 // maps a log's logical logation in its stream, prefix, and timeline to its
 // frame's binary offset in the archived log stream blob.
 type LogIndex struct {
         //
@@ skipping 37 matching lines @@
 // Entry is a single index entry.
 //
 // The index is composed of a series of entries, each corresponding to a
 // sequential snapshot of of the log stream.
 type LogIndex_Entry struct {
         //
         // The byte offset record in the indexed stream file (required).
         //
         // This is used by clients to request specific LogEntry from an archived
         // log stream.
-        Offset *uint64 `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"`
+        Offset *uint32 `protobuf:"varint,1,opt,name=offset" json:"offset,omitempty"`
         //
         // The log index that this entry describes (required).
         //
         // This is used by clients to identify a specific LogEntry within a set of
         // streams sharing a Prefix.
-        PrefixIndex *uint64 `protobuf:"varint,2,opt,name=prefix_index" json:"prefix_index,omitempty"`
+        PrefixIndex *uint32 `protobuf:"varint,2,opt,name=prefix_index" json:"prefix_index,omitempty"`
         //
         // The time offset of this log entry (required).
         //
         // This is used by clients to identify a specific LogEntry within a log
         // stream.
-        StreamIndex *uint64 `protobuf:"varint,3,opt,name=stream_index" json:"stream_index,omitempty"`
+        StreamIndex *uint32 `protobuf:"varint,3,opt,name=stream_index" json:"stream_index,omitempty"`
         //
         // The time offset of this log entry, in microseconds.
         //
         // This is added to the descriptor's "timestamp" field to identify the
         // specific timestamp of this log. It is used by clients to identify a
         // specific LogEntry by time.
-        TimeOffsetUs     *uint64 `protobuf:"varint,4,opt,name=time_offset_us" json:"time_offset_us,omitempty"`
+        TimeOffsetUs     *uint32 `protobuf:"varint,4,opt,name=time_offset_us" json:"time_offset_us,omitempty"`
         XXX_unrecognized []byte  `json:"-"`
 }
 
 func (m *LogIndex_Entry) Reset()         { *m = LogIndex_Entry{} }
 func (m *LogIndex_Entry) String() string { return proto.CompactTextString(m) }
 func (*LogIndex_Entry) ProtoMessage()    {}
 
-func (m *LogIndex_Entry) GetOffset() uint64 {
+func (m *LogIndex_Entry) GetOffset() uint32 {
         if m != nil && m.Offset != nil {
                 return *m.Offset
         }
         return 0
 }
 
-func (m *LogIndex_Entry) GetPrefixIndex() uint64 {
+func (m *LogIndex_Entry) GetPrefixIndex() uint32 {
         if m != nil && m.PrefixIndex != nil {
                 return *m.PrefixIndex
         }
         return 0
 }
 
-func (m *LogIndex_Entry) GetStreamIndex() uint64 {
+func (m *LogIndex_Entry) GetStreamIndex() uint32 {
         if m != nil && m.StreamIndex != nil {
                 return *m.StreamIndex
         }
         return 0
 }
 
-func (m *LogIndex_Entry) GetTimeOffsetUs() uint64 {
+func (m *LogIndex_Entry) GetTimeOffsetUs() uint32 {
         if m != nil && m.TimeOffsetUs != nil {
                 return *m.TimeOffsetUs
         }
         return 0
 }
 
 func init() {
 }