blob: f1ea19f3fbf182568a4d71c9cd1efa56e77fd783 [file] [log] [blame]
// Code generated by protoc-gen-go. DO NOT EDIT.
// source:
package jobsim
import (
fmt "fmt"
proto ""
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.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.ProtoPackageIsVersion3 // please upgrade the proto package
// 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,proto3" 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=doPollback,proto3" json:"do_pollback,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
func (m *Config) Reset() { *m = Config{} }
func (m *Config) String() string { return proto.CompactTextString(m) }
func (*Config) ProtoMessage() {}
func (*Config) Descriptor() ([]byte, []int) {
return fileDescriptor_cabdc2d418c4e740, []int{0}
func (m *Config) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_Config.Unmarshal(m, b)
func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_Config.Marshal(b, m, deterministic)
func (m *Config) XXX_Merge(src proto.Message) {
xxx_messageInfo_Config.Merge(m, src)
func (m *Config) XXX_Size() int {
return xxx_messageInfo_Config.Size(m)
func (m *Config) XXX_DiscardUnknown() {
var xxx_messageInfo_Config proto.InternalMessageInfo
func (m *Config) GetPool() string {
if m != nil {
return m.Pool
return ""
func (m *Config) GetDoPollback() bool {
if m != nil {
return m.DoPollback
return false
func init() {
proto.RegisterType((*Config)(nil), "jobsim.Config")
func init() {
proto.RegisterFile("", fileDescriptor_cabdc2d418c4e740)
var fileDescriptor_cabdc2d418c4e740 = []byte{
// 142 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x2c, 0x8c, 0xb1, 0x0e, 0xc2, 0x20,
0x14, 0x45, 0x83, 0x31, 0x44, 0x71, 0x63, 0xea, 0x66, 0xe3, 0xd4, 0x09, 0x06, 0x47, 0xe3, 0xe4,
0x0f, 0x98, 0xfe, 0x80, 0x29, 0x10, 0xf1, 0x29, 0x78, 0xc9, 0x2b, 0xfc, 0xbf, 0x49, 0xed, 0x74,
0xef, 0x39, 0xc3, 0x51, 0x97, 0x08, 0xe3, 0x5f, 0x8c, 0x4c, 0x2d, 0x1b, 0x70, 0xb4, 0xa9, 0x79,
0xb2, 0x21, 0xdb, 0xa9, 0x90, 0x0d, 0x34, 0x57, 0x26, 0xd7, 0x2a, 0xd8, 0xbe, 0xe1, 0x66, 0xca,
0xeb, 0x98, 0xc2, 0xa8, 0xd0, 0xf2, 0x4f, 0xa7, 0xab, 0x92, 0x37, 0x7c, 0x9f, 0x14, 0xb5, 0x56,
0xdb, 0x02, 0xa4, 0x4e, 0xf4, 0x62, 0xd8, 0x8f, 0xcb, 0xd7, 0x47, 0x75, 0x08, 0x78, 0x14, 0xa4,
0xe4, 0x26, 0xff, 0xe9, 0x36, 0xbd, 0x18, 0x76, 0xa3, 0x0a, 0xb8, 0xaf, 0xc6, 0xc9, 0xa5, 0x76,
0xfe, 0x05, 0x00, 0x00, 0xff, 0xff, 0x13, 0xd1, 0xbb, 0x4c, 0x8c, 0x00, 0x00, 0x00,