-
Notifications
You must be signed in to change notification settings - Fork 1
/
Copy pathself-describing-message.pb.go
119 lines (106 loc) · 5.01 KB
/
self-describing-message.pb.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
// Code generated by protoc-gen-go.
// source: self-describing-message.proto
// DO NOT EDIT!
package dicoprotos
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
type SelfDescribingMessage_MessageType int32
const (
SelfDescribingMessage_DO_TASK SelfDescribingMessage_MessageType = 1
SelfDescribingMessage_TASK_STATUS SelfDescribingMessage_MessageType = 2
SelfDescribingMessage_TASK_RESULT SelfDescribingMessage_MessageType = 3
SelfDescribingMessage_SUBMIT_TASK SelfDescribingMessage_MessageType = 4
SelfDescribingMessage_HANDSHAKE SelfDescribingMessage_MessageType = 5
SelfDescribingMessage_SUBMIT_CODE SelfDescribingMessage_MessageType = 6
SelfDescribingMessage_WORKER_STATUS SelfDescribingMessage_MessageType = 7
SelfDescribingMessage_JOB_CLASS_CREATED SelfDescribingMessage_MessageType = 8
)
var SelfDescribingMessage_MessageType_name = map[int32]string{
1: "DO_TASK",
2: "TASK_STATUS",
3: "TASK_RESULT",
4: "SUBMIT_TASK",
5: "HANDSHAKE",
6: "SUBMIT_CODE",
7: "WORKER_STATUS",
8: "JOB_CLASS_CREATED",
}
var SelfDescribingMessage_MessageType_value = map[string]int32{
"DO_TASK": 1,
"TASK_STATUS": 2,
"TASK_RESULT": 3,
"SUBMIT_TASK": 4,
"HANDSHAKE": 5,
"SUBMIT_CODE": 6,
"WORKER_STATUS": 7,
"JOB_CLASS_CREATED": 8,
}
func (x SelfDescribingMessage_MessageType) Enum() *SelfDescribingMessage_MessageType {
p := new(SelfDescribingMessage_MessageType)
*p = x
return p
}
func (x SelfDescribingMessage_MessageType) String() string {
return proto.EnumName(SelfDescribingMessage_MessageType_name, int32(x))
}
func (x *SelfDescribingMessage_MessageType) UnmarshalJSON(data []byte) error {
value, err := proto.UnmarshalJSONEnum(SelfDescribingMessage_MessageType_value, data, "SelfDescribingMessage_MessageType")
if err != nil {
return err
}
*x = SelfDescribingMessage_MessageType(value)
return nil
}
func (SelfDescribingMessage_MessageType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor3, []int{0, 0}
}
type SelfDescribingMessage struct {
Type *SelfDescribingMessage_MessageType `protobuf:"varint,1,req,name=type,enum=dicoprotos.SelfDescribingMessage_MessageType" json:"type,omitempty"`
Data []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"`
XXX_unrecognized []byte `json:"-"`
}
func (m *SelfDescribingMessage) Reset() { *m = SelfDescribingMessage{} }
func (m *SelfDescribingMessage) String() string { return proto.CompactTextString(m) }
func (*SelfDescribingMessage) ProtoMessage() {}
func (*SelfDescribingMessage) Descriptor() ([]byte, []int) { return fileDescriptor3, []int{0} }
func (m *SelfDescribingMessage) GetType() SelfDescribingMessage_MessageType {
if m != nil && m.Type != nil {
return *m.Type
}
return SelfDescribingMessage_DO_TASK
}
func (m *SelfDescribingMessage) GetData() []byte {
if m != nil {
return m.Data
}
return nil
}
func init() {
proto.RegisterType((*SelfDescribingMessage)(nil), "dicoprotos.SelfDescribingMessage")
proto.RegisterEnum("dicoprotos.SelfDescribingMessage_MessageType", SelfDescribingMessage_MessageType_name, SelfDescribingMessage_MessageType_value)
}
var fileDescriptor3 = []byte{
// 264 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x09, 0x6e, 0x88, 0x02, 0xff, 0xe2, 0x92, 0x2d, 0x4e, 0xcd, 0x49,
0xd3, 0x4d, 0x49, 0x2d, 0x4e, 0x2e, 0xca, 0x4c, 0xca, 0xcc, 0x4b, 0xd7, 0xcd, 0x4d, 0x2d, 0x2e,
0x4e, 0x4c, 0x4f, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0xe2, 0x4a, 0xc9, 0x4c, 0xce, 0x07,
0x33, 0x8b, 0x95, 0xfe, 0x30, 0x72, 0x89, 0x06, 0x03, 0x55, 0xbb, 0xc0, 0x15, 0xfb, 0x42, 0xd4,
0x0a, 0x59, 0x73, 0xb1, 0x94, 0x54, 0x16, 0xa4, 0x4a, 0x30, 0x2a, 0x30, 0x69, 0xf0, 0x19, 0xe9,
0xea, 0x21, 0x34, 0xe9, 0x61, 0xd5, 0xa0, 0x07, 0xa5, 0x43, 0x80, 0x9a, 0x84, 0x78, 0xb8, 0x58,
0x52, 0x12, 0x4b, 0x12, 0x25, 0x98, 0x80, 0x9a, 0x79, 0x94, 0xa6, 0x33, 0x72, 0x71, 0x23, 0xcb,
0x72, 0x73, 0xb1, 0xbb, 0xf8, 0xc7, 0x87, 0x38, 0x06, 0x7b, 0x0b, 0x30, 0x0a, 0xf1, 0x73, 0x71,
0x83, 0x58, 0xf1, 0xc1, 0x21, 0x8e, 0x21, 0xa1, 0xc1, 0x02, 0x4c, 0x70, 0x81, 0x20, 0xd7, 0xe0,
0x50, 0x9f, 0x10, 0x01, 0x66, 0x90, 0x40, 0x70, 0xa8, 0x93, 0xaf, 0x67, 0x08, 0x44, 0x0b, 0x8b,
0x10, 0x2f, 0x17, 0xa7, 0x87, 0xa3, 0x9f, 0x4b, 0xb0, 0x87, 0xa3, 0xb7, 0xab, 0x00, 0x2b, 0x92,
0xbc, 0xb3, 0xbf, 0x8b, 0xab, 0x00, 0x9b, 0x90, 0x20, 0x17, 0x6f, 0xb8, 0x7f, 0x90, 0xb7, 0x6b,
0x10, 0xcc, 0x50, 0x76, 0x21, 0x51, 0x2e, 0x41, 0x2f, 0x7f, 0xa7, 0x78, 0x67, 0x1f, 0xc7, 0xe0,
0xe0, 0x78, 0xe7, 0x20, 0x57, 0xc7, 0x10, 0x57, 0x17, 0x01, 0x0e, 0x27, 0x0b, 0x2e, 0xa9, 0xe4,
0xfc, 0x5c, 0xbd, 0xe4, 0x8c, 0xd4, 0xa2, 0xa2, 0xca, 0xf2, 0xfc, 0xa2, 0x5c, 0xb0, 0x37, 0x21,
0xe1, 0x54, 0xec, 0x24, 0x85, 0xd5, 0xa3, 0x01, 0x20, 0x49, 0x40, 0x00, 0x00, 0x00, 0xff, 0xff,
0x36, 0x84, 0xf6, 0x94, 0x64, 0x01, 0x00, 0x00,
}