Initial distributor implementation

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

 // Code generated by protoc-gen-go.
 // source: ensure_graph_data.proto
 // DO NOT EDIT!
 
 package dm
 
 import proto "github.com/golang/protobuf/proto"
 import fmt "fmt"
 import math "math"
 import template "github.com/luci/luci-go/common/api/template"
@@ skipping 12 matching lines @@
         // 'refs/heads/master').
         Ref string `protobuf:"bytes,2,opt,name=ref" json:"ref,omitempty"`
         // specifier specifies the actual template name, as well as any substitution
         // parameters which that template might require.
         Specifier *template.Specifier `protobuf:"bytes,4,opt,name=specifier" json:"specifier,omitempty"`
 }
 
 func (m *TemplateInstantiation) Reset()                    { *m = TemplateInstantiation{} }
 func (m *TemplateInstantiation) String() string            { return proto.CompactTextString(m) }
 func (*TemplateInstantiation) ProtoMessage()               {}
-func (*TemplateInstantiation) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{0} }
+func (*TemplateInstantiation) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{0} }
 
 func (m *TemplateInstantiation) GetSpecifier() *template.Specifier {
         if m != nil {
                 return m.Specifier
         }
         return nil
 }
 
 // EnsureGraphDataReq allows you to assert some things about the state of DM's
 // graph:
@@ skipping 36 matching lines @@
         // and any quests/attempts provided will be made standalone (e.g. nothing will
         // depend on them).
         ForExecution *Execution_Auth             `protobuf:"bytes,5,opt,name=for_execution,json=forExecution" json:"for_execution,omitempty"`
         Limit        *EnsureGraphDataReq_Limit   `protobuf:"bytes,6,opt,name=limit" json:"limit,omitempty"`
         Include      *EnsureGraphDataReq_Include `protobuf:"bytes,7,opt,name=include" json:"include,omitempty"`
 }
 
 func (m *EnsureGraphDataReq) Reset()                    { *m = EnsureGraphDataReq{} }
 func (m *EnsureGraphDataReq) String() string            { return proto.CompactTextString(m) }
 func (*EnsureGraphDataReq) ProtoMessage()               {}
-func (*EnsureGraphDataReq) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{1} }
+func (*EnsureGraphDataReq) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{1} }
 
 func (m *EnsureGraphDataReq) GetQuest() []*Quest_Desc {
         if m != nil {
                 return m.Quest
         }
         return nil
 }
 
 func (m *EnsureGraphDataReq) GetAttempts() *AttemptList {
         if m != nil {
@@ skipping 44 matching lines @@
         // object would still be included in the result.
         //
         // If this limit is 0, a default limit of 16MB will be used. If this limit
         // exceeds 30MB, it will be reduced to 30MB.
         MaxDataSize uint32 `protobuf:"varint,3,opt,name=max_data_size,json=maxDataSize" json:"max_data_size,omitempty"`
 }
 
 func (m *EnsureGraphDataReq_Limit) Reset()                    { *m = EnsureGraphDataReq_Limit{} }
 func (m *EnsureGraphDataReq_Limit) String() string            { return proto.CompactTextString(m) }
 func (*EnsureGraphDataReq_Limit) ProtoMessage()               {}
-func (*EnsureGraphDataReq_Limit) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{1, 0} }
+func (*EnsureGraphDataReq_Limit) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{1, 0} }
 
 type EnsureGraphDataReq_Include struct {
         // AttemptResult will include the Attempt result payloads for any Attempts
         // that it returns were already in the Finished state.
         //
         // If the request would return more than limit.max_data_size of data, the
         // remaining attempt results will have their Partial.Data field set to true.
         AttemptResult bool `protobuf:"varint,4,opt,name=attempt_result,json=attemptResult" json:"attempt_result,omitempty"`
 }
 
 func (m *EnsureGraphDataReq_Include) Reset()                    { *m = EnsureGraphDataReq_Include{} }
 func (m *EnsureGraphDataReq_Include) String() string            { return proto.CompactTextString(m) }
 func (*EnsureGraphDataReq_Include) ProtoMessage()               {}
-func (*EnsureGraphDataReq_Include) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{1, 1} }
+func (*EnsureGraphDataReq_Include) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{1, 1} }
 
 type EnsureGraphDataRsp struct {
         // accepted is true when all new graph data was journaled successfully. This
         // means that `quests`, `attempts`, `template_quest`, `template_attempt` were
         // all well-formed and are scheduled to be added. They will 'eventually' be
         // readable via other APIs (like WalkGraph), but when they are, they'll have
         // the IDs reflected in this response.
         //
         // If `attempts` referrs to quests that don't exist and weren't provided in
         // `quests`, those quests will be listed in `result` with the DNE flag set.
@@ skipping 34 matching lines @@
         // auth Token is also revoked and will no longer work for futher API calls.
         //
         // If `for_execution` was provided in the request and this is false, it means
         // that the execution may continue executing.
         ShouldHalt bool `protobuf:"varint,5,opt,name=should_halt,json=shouldHalt" json:"should_halt,omitempty"`
 }
 
 func (m *EnsureGraphDataRsp) Reset()                    { *m = EnsureGraphDataRsp{} }
 func (m *EnsureGraphDataRsp) String() string            { return proto.CompactTextString(m) }
 func (*EnsureGraphDataRsp) ProtoMessage()               {}
-func (*EnsureGraphDataRsp) Descriptor() ([]byte, []int) { return fileDescriptor2, []int{2} }
+func (*EnsureGraphDataRsp) Descriptor() ([]byte, []int) { return fileDescriptor1, []int{2} }
 
 func (m *EnsureGraphDataRsp) GetTemplateIds() []*Quest_ID {
         if m != nil {
                 return m.TemplateIds
         }
         return nil
 }
 
 func (m *EnsureGraphDataRsp) GetResult() *GraphData {
         if m != nil {
                 return m.Result
         }
         return nil
 }
 
 func init() {
         proto.RegisterType((*TemplateInstantiation)(nil), "dm.TemplateInstantiation")
         proto.RegisterType((*EnsureGraphDataReq)(nil), "dm.EnsureGraphDataReq")
         proto.RegisterType((*EnsureGraphDataReq_Limit)(nil), "dm.EnsureGraphDataReq.Limit")
         proto.RegisterType((*EnsureGraphDataReq_Include)(nil), "dm.EnsureGraphDataReq.Include")
         proto.RegisterType((*EnsureGraphDataRsp)(nil), "dm.EnsureGraphDataRsp")
 }
 
-var fileDescriptor2 = []byte{
+var fileDescriptor1 = []byte{
         // 561 bytes of a gzipped FileDescriptorProto
         0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0x74, 0x53, 0x5d, 0x8b, 0xd3, 0x40,
         0x14, 0xa5, 0x1f, 0x69, 0xd2, 0x49, 0xd3, 0x0d, 0xa3, 0x62, 0x0c, 0xa2, 0x52, 0x14, 0x16, 0xc4,
         0x14, 0xeb, 0xc3, 0x8a, 0x2f, 0xba, 0xd0, 0xa2, 0x95, 0x45, 0x70, 0xd6, 0x27, 0x5f, 0x42, 0x36,
         0x99, 0x36, 0x23, 0xf9, 0xda, 0xcc, 0x0c, 0xac, 0xe2, 0xef, 0xf1, 0xf7, 0xf8, 0x93, 0xbc, 0x33,
         0xf9, 0xe8, 0xb2, 0xeb, 0xbe, 0x5c, 0x9a, 0x33, 0xe7, 0x9c, 0x7b, 0xef, 0xcc, 0x29, 0x7a, 0x48,
         0x0b, 0x2e, 0x6b, 0x1a, 0xee, 0xeb, 0xa8, 0x4a, 0xc3, 0x24, 0x12, 0x51, 0x50, 0xd5, 0xa5, 0x28,
         0xf1, 0x30, 0xc9, 0x7d, 0x5b, 0xfc, 0xac, 0x28, 0x6f, 0x00, 0xdf, 0xbd, 0x49, 0xf1, 0xdf, 0xed,
         0x99, 0x48, 0xe5, 0x45, 0x10, 0x97, 0xf9, 0x32, 0x93, 0x31, 0xd3, 0xe5, 0xd5, 0xbe, 0x5c, 0x02,
         0x90, 0x97, 0xc5, 0x32, 0xaa, 0xd8, 0x52, 0xd0, 0xbc, 0xca, 0x22, 0x41, 0xfb, 0x1f, 0x8d, 0x76,
@@ skipping 18 matching lines @@
         0x58, 0xc4, 0x69, 0x51, 0xa2, 0xc1, 0xeb, 0xea, 0x26, 0x10, 0x50, 0x0d, 0x77, 0x02, 0x75, 0xe2,
         0x9a, 0x50, 0x4d, 0xd7, 0x82, 0x6a, 0xb9, 0xd3, 0xc5, 0xdf, 0xc1, 0xed, 0xa0, 0xf0, 0x0a, 0xfb,
         0x10, 0x81, 0x38, 0xa6, 0x95, 0xa0, 0x89, 0x4e, 0xa9, 0x45, 0xfa, 0x6f, 0xbc, 0x44, 0xb3, 0xfe,
         0xbd, 0x58, 0xa2, 0x22, 0xa2, 0xde, 0x6a, 0x76, 0xc8, 0xd2, 0x76, 0x4d, 0xec, 0x8e, 0xb1, 0x4d,
         0xb8, 0x1a, 0xba, 0x17, 0xd0, 0xba, 0x2e, 0x6b, 0x1d, 0x91, 0xe9, 0x21, 0x07, 0x1b, 0x05, 0x02,
         0x6d, 0x72, 0x6d, 0x27, 0x7b, 0xe5, 0x28, 0xc7, 0xc3, 0x54, 0xed, 0x21, 0x7e, 0x8a, 0x6c, 0x9e,
         0x96, 0x32, 0x4b, 0xc2, 0x34, 0x02, 0xae, 0xa1, 0xa7, 0x43, 0x0d, 0xf4, 0x09, 0x90, 0x8b, 0x89,
         0xfe, 0x03, 0xbe, 0xf9, 0x17, 0x00, 0x00, 0xff, 0xff, 0x68, 0x1b, 0xe7, 0xe4, 0xfa, 0x03, 0x00,
         0x00,
 }