Initial distributor implementation

common/api/dm/service/v1/types.pb.go

 // Code generated by protoc-gen-go.
 // source: types.proto
 // DO NOT EDIT!
 
 package dm
 
 import proto "github.com/golang/protobuf/proto"
 import fmt "fmt"
 import math "math"
 import google_protobuf "github.com/luci/luci-go/common/proto/google"
-import google_protobuf1 "github.com/luci/luci-go/common/proto/google"
+import google_protobuf2 "github.com/luci/luci-go/common/proto/google"
 
 // Reference imports to suppress errors if they are not otherwise used.
 var _ = proto.Marshal
 var _ = fmt.Errorf
 var _ = math.Inf
 
 type MultiPropertyValue struct {
         Values []*PropertyValue `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
 }
 
 func (m *MultiPropertyValue) Reset()                    { *m = MultiPropertyValue{} }
 func (m *MultiPropertyValue) String() string            { return proto.CompactTextString(m) }
 func (*MultiPropertyValue) ProtoMessage()               {}
-func (*MultiPropertyValue) Descriptor() ([]byte, []int) { return fileDescriptor7, []int{0} }
+func (*MultiPropertyValue) Descriptor() ([]byte, []int) { return fileDescriptor6, []int{0} }
 
 func (m *MultiPropertyValue) GetValues() []*PropertyValue {
         if m != nil {
                 return m.Values
         }
         return nil
 }
 
 type PropertyValue struct {
         // Types that are valid to be assigned to Value:
         //      *PropertyValue_Str
         //      *PropertyValue_Dat
         //      *PropertyValue_Num
         //      *PropertyValue_Bin
         //      *PropertyValue_Time
         //      *PropertyValue_Null
         Value isPropertyValue_Value `protobuf_oneof:"value"`
 }
 
 func (m *PropertyValue) Reset()                    { *m = PropertyValue{} }
 func (m *PropertyValue) String() string            { return proto.CompactTextString(m) }
 func (*PropertyValue) ProtoMessage()               {}
-func (*PropertyValue) Descriptor() ([]byte, []int) { return fileDescriptor7, []int{1} }
+func (*PropertyValue) Descriptor() ([]byte, []int) { return fileDescriptor6, []int{1} }
 
 type isPropertyValue_Value interface {
         isPropertyValue_Value()
 }
 
 type PropertyValue_Str struct {
         Str string `protobuf:"bytes,1,opt,name=str,oneof"`
 }
 type PropertyValue_Dat struct {
         Dat []byte `protobuf:"bytes,2,opt,name=dat,proto3,oneof"`
 }
 type PropertyValue_Num struct {
         Num int64 `protobuf:"varint,3,opt,name=num,oneof"`
 }
 type PropertyValue_Bin struct {
         Bin bool `protobuf:"varint,5,opt,name=bin,oneof"`
 }
 type PropertyValue_Time struct {
         Time *google_protobuf.Timestamp `protobuf:"bytes,6,opt,name=time,oneof"`
 }
 type PropertyValue_Null struct {
-        Null *google_protobuf1.Empty `protobuf:"bytes,7,opt,name=null,oneof"`
+        Null *google_protobuf2.Empty `protobuf:"bytes,7,opt,name=null,oneof"`
 }
 
 func (*PropertyValue_Str) isPropertyValue_Value()  {}
 func (*PropertyValue_Dat) isPropertyValue_Value()  {}
 func (*PropertyValue_Num) isPropertyValue_Value()  {}
 func (*PropertyValue_Bin) isPropertyValue_Value()  {}
 func (*PropertyValue_Time) isPropertyValue_Value() {}
 func (*PropertyValue_Null) isPropertyValue_Value() {}
 
 func (m *PropertyValue) GetValue() isPropertyValue_Value {
@@ skipping 31 matching lines @@
         return false
 }
 
 func (m *PropertyValue) GetTime() *google_protobuf.Timestamp {
         if x, ok := m.GetValue().(*PropertyValue_Time); ok {
                 return x.Time
         }
         return nil
 }
 
-func (m *PropertyValue) GetNull() *google_protobuf1.Empty {
+func (m *PropertyValue) GetNull() *google_protobuf2.Empty {
         if x, ok := m.GetValue().(*PropertyValue_Null); ok {
                 return x.Null
         }
         return nil
 }
 
 // XXX_OneofFuncs is for the internal use of the proto package.
 func (*PropertyValue) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{}) {
         return _PropertyValue_OneofMarshaler, _PropertyValue_OneofUnmarshaler, _PropertyValue_OneofSizer, []interface{}{
                 (*PropertyValue_Str)(nil),
@@ skipping 78 matching lines @@
                         return true, proto.ErrInternalBadWireType
                 }
                 msg := new(google_protobuf.Timestamp)
                 err := b.DecodeMessage(msg)
                 m.Value = &PropertyValue_Time{msg}
                 return true, err
         case 7: // value.null
                 if wire != proto.WireBytes {
                         return true, proto.ErrInternalBadWireType
                 }
-                msg := new(google_protobuf1.Empty)
+                msg := new(google_protobuf2.Empty)
                 err := b.DecodeMessage(msg)
                 m.Value = &PropertyValue_Null{msg}
                 return true, err
         default:
                 return false, nil
         }
 }
 
 func _PropertyValue_OneofSizer(msg proto.Message) (n int) {
         m := msg.(*PropertyValue)
@@ skipping 39 matching lines @@
         //   {
         //     "foo": [1, 2],
         //     "bar": [1],
         //   }
         To map[string]*AttemptList_Nums `protobuf:"bytes,2,rep,name=to" json:"to,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
 }
 
 func (m *AttemptList) Reset()                    { *m = AttemptList{} }
 func (m *AttemptList) String() string            { return proto.CompactTextString(m) }
 func (*AttemptList) ProtoMessage()               {}
-func (*AttemptList) Descriptor() ([]byte, []int) { return fileDescriptor7, []int{2} }
+func (*AttemptList) Descriptor() ([]byte, []int) { return fileDescriptor6, []int{2} }
 
 func (m *AttemptList) GetTo() map[string]*AttemptList_Nums {
         if m != nil {
                 return m.To
         }
         return nil
 }
 
 type AttemptList_Nums struct {
         Nums []uint32 `protobuf:"varint,1,rep,packed,name=nums" json:"nums,omitempty"`
 }
 
 func (m *AttemptList_Nums) Reset()                    { *m = AttemptList_Nums{} }
 func (m *AttemptList_Nums) String() string            { return proto.CompactTextString(m) }
 func (*AttemptList_Nums) ProtoMessage()               {}
-func (*AttemptList_Nums) Descriptor() ([]byte, []int) { return fileDescriptor7, []int{2, 0} }
+func (*AttemptList_Nums) Descriptor() ([]byte, []int) { return fileDescriptor6, []int{2, 0} }
 
 func init() {
         proto.RegisterType((*MultiPropertyValue)(nil), "dm.MultiPropertyValue")
         proto.RegisterType((*PropertyValue)(nil), "dm.PropertyValue")
         proto.RegisterType((*AttemptList)(nil), "dm.AttemptList")
         proto.RegisterType((*AttemptList_Nums)(nil), "dm.AttemptList.Nums")
 }
 
-var fileDescriptor7 = []byte{
+var fileDescriptor6 = []byte{
         // 340 bytes of a gzipped FileDescriptorProto
         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x64, 0x90, 0x5d, 0x4b, 0xc3, 0x30,
         0x14, 0x86, 0xed, 0xc7, 0x3e, 0x3c, 0x75, 0x30, 0x83, 0xcc, 0x52, 0x41, 0x65, 0x37, 0x4e, 0x91,
         0x4c, 0xe6, 0x8d, 0x78, 0x23, 0x0e, 0x06, 0xe2, 0x17, 0x52, 0x86, 0xf7, 0x1b, 0x8b, 0xa3, 0xd8,
         0x34, 0xa5, 0x3d, 0x15, 0xfa, 0x7b, 0xfc, 0x3f, 0xfe, 0x26, 0x73, 0x92, 0x0d, 0xdc, 0xbc, 0xeb,
         0x79, 0xf2, 0x9c, 0x26, 0xef, 0x0b, 0x01, 0xd6, 0xb9, 0x28, 0x79, 0x5e, 0x28, 0x54, 0xcc, 0x5d,
         0xc8, 0xe8, 0x64, 0xa9, 0xd4, 0x32, 0x15, 0x43, 0x43, 0xe6, 0xd5, 0xc7, 0x10, 0x13, 0x29, 0x4a,
         0x9c, 0xc9, 0xdc, 0x4a, 0xd1, 0xd1, 0xb6, 0x20, 0x64, 0x8e, 0xb5, 0x3d, 0xec, 0xdf, 0x01, 0x7b,
         0xa9, 0x52, 0x4c, 0xde, 0x0a, 0x95, 0x8b, 0x02, 0xeb, 0xf7, 0x59, 0x5a, 0x09, 0x76, 0x0e, 0xcd,
         0x2f, 0xfa, 0x28, 0x43, 0xe7, 0xd4, 0x1b, 0x04, 0xa3, 0x7d, 0xbe, 0x90, 0x7c, 0x43, 0x89, 0x57,
         0x42, 0xff, 0xc7, 0x81, 0xce, 0xe6, 0x32, 0x03, 0xaf, 0xc4, 0x42, 0x6f, 0x3a, 0x83, 0xdd, 0x87,
         0x9d, 0x98, 0x06, 0x62, 0x8b, 0x19, 0x86, 0xae, 0x66, 0x7b, 0xc4, 0xf4, 0x40, 0x2c, 0xab, 0x64,
         0xe8, 0x69, 0xe6, 0x11, 0xd3, 0x03, 0xb1, 0x79, 0x92, 0x85, 0x0d, 0xcd, 0xda, 0xc4, 0xf4, 0xc0,
         0xae, 0xc0, 0xa7, 0x48, 0x61, 0x53, 0xc3, 0x60, 0x14, 0x71, 0x1b, 0x87, 0xaf, 0xe3, 0xf0, 0xe9,
         0x3a, 0xaf, 0x5e, 0x30, 0x26, 0xbb, 0x04, 0x3f, 0xab, 0xd2, 0x34, 0x6c, 0x99, 0x8d, 0xde, 0xbf,
         0x8d, 0x09, 0x15, 0x40, 0x36, 0x59, 0xe3, 0x16, 0x34, 0x4c, 0x96, 0x47, 0xbf, 0xed, 0x77, 0x1b,
         0xfd, 0x6f, 0x07, 0x82, 0x7b, 0x44, 0x2a, 0xe9, 0x39, 0x29, 0x91, 0x9d, 0x81, 0x8b, 0x4a, 0xbf,
         0x9c, 0x7a, 0x38, 0xa4, 0x1e, 0xfe, 0x1c, 0xf2, 0xa9, 0x9a, 0x64, 0x58, 0xd4, 0xb1, 0x56, 0xa2,
         0x63, 0xf0, 0x5f, 0x2b, 0x59, 0xb2, 0x1e, 0xdd, 0x2e, 0x6d, 0x75, 0x9d, 0xb1, 0xdb, 0x75, 0x62,
         0x33, 0x47, 0x4f, 0xd0, 0x5a, 0xe9, 0xac, 0x0b, 0xde, 0xa7, 0xa8, 0x6d, 0x45, 0x31, 0x7d, 0xb2,
         0x8b, 0xd5, 0x23, 0x4c, 0x45, 0xc1, 0xe8, 0x60, 0xfb, 0x22, 0xfa, 0x73, 0x6c, 0x95, 0x5b, 0xf7,
         0xc6, 0x99, 0x37, 0x4d, 0x98, 0xeb, 0xdf, 0x00, 0x00, 0x00, 0xff, 0xff, 0x29, 0x51, 0x52, 0x94,
         0x0f, 0x02, 0x00, 0x00,
 }