Initial distributor implementation

appengine/cmd/dm/distributor/protos/jobsim/jobsim.pb.go

Index: appengine/cmd/dm/distributor/protos/jobsim/jobsim.pb.go
diff --git a/appengine/cmd/dm/distributor/protos/jobsim/jobsim.pb.go b/appengine/cmd/dm/distributor/protos/jobsim/jobsim.pb.go
new file mode 100644
index 0000000000000000000000000000000000000000..5c6c50f245bd330304c32601e9b6099485128f91
--- /dev/null
+++ b/appengine/cmd/dm/distributor/protos/jobsim/jobsim.pb.go
@@ -0,0 +1,63 @@
+// Code generated by protoc-gen-go.
+// source: jobsim.proto
+// DO NOT EDIT!
+
+/*
+Package jobsim is a generated protocol buffer package.
+
+It is generated from these files:
+	jobsim.proto
+
+It has these top-level messages:
+	Config
+*/
+package jobsim
+
+import proto "github.com/golang/protobuf/proto"
+import fmt "fmt"
+import math "math"
+
+// Reference imports to suppress errors if they are not otherwise used.
+var _ = proto.Marshal
+var _ = fmt.Errorf
+var _ = math.Inf
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the proto package it is being compiled against.
+const _ = proto.ProtoPackageIsVersion1
+
+// Config is ONLY for testing purposes in dm/service. However, because of the
+// way that the distributor proto works it needs to be included in the main
+// distributor.proto file. For consistency, this jobsim proto lives here.
+type Config struct {
+	// Pool specifies the unique 'pool' name for this jobsim configuration. This
+	// will be used to namespace jobsim objects in the datastore, and can be used
+	// to demonstrate cross-distributor dependencies (by having one pool's jobs
+	// depend on another pool's results).
+	Pool string `protobuf:"bytes,1,opt,name=pool" json:"pool,omitempty"`
+	// DoPollback controls whether or not this configuration will force DM to
+	// poll back when recieving a HandleNotification. If this is true, then
+	// HandleNotification will return (nil, nil), and DM will call GetStatus
+	// at some later point. If this is false, then HandleNotification will
+	// directly return the job's status.
+	DoPollback bool `protobuf:"varint,2,opt,name=do_pollback" json:"do_pollback,omitempty"`
+}
+
+func (m *Config) Reset()                    { *m = Config{} }
+func (m *Config) String() string            { return proto.CompactTextString(m) }
+func (*Config) ProtoMessage()               {}
+func (*Config) Descriptor() ([]byte, []int) { return fileDescriptor0, []int{0} }
+
+func init() {
+	proto.RegisterType((*Config)(nil), "jobsim.Config")
+}
+
+var fileDescriptor0 = []byte{
+	// 91 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xe2, 0xe2, 0xc9, 0xca, 0x4f, 0x2a,
+	0xce, 0xcc, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0x62, 0x83, 0xf0, 0x94, 0xb4, 0xb9, 0xd8,
+	0x9c, 0xf3, 0xf3, 0xd2, 0x32, 0xd3, 0x85, 0x78, 0xb8, 0x58, 0x0a, 0xf2, 0xf3, 0x73, 0x24, 0x18,
+	0x15, 0x18, 0x35, 0x38, 0x85, 0x84, 0xb9, 0xb8, 0x53, 0xf2, 0xe3, 0x0b, 0xf2, 0x73, 0x72, 0x92,
+	0x12, 0x93, 0xb3, 0x25, 0x98, 0x80, 0x82, 0x1c, 0x49, 0x6c, 0x60, 0xbd, 0xc6, 0x80, 0x00, 0x00,
+	0x00, 0xff, 0xff, 0x50, 0x64, 0x31, 0xa3, 0x4b, 0x00, 0x00, 0x00,
+}