Skip to content

O
OdysseusProtocol
Commit b896174b authored by vicotor's avatar vicotor
Browse files
Options

add new message

parent c3e15adf
Hide whitespace changes
Inline Side-by-side
Showing with 152 additions and 93 deletions
gen/proto/go/nodemanager/v1/request_response.pb.go
View file @ b896174b
......@@ -34,6 +34,7 @@ type WorkerMessage struct {
// *WorkerMessage_FetchStandardTask
// *WorkerMessage_RegisteMessage
// *WorkerMessage_NodeInfo
// *WorkerMessage_SubmitTaskAck
Message isWorkerMessage_Message `protobuf_oneof:"message"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
......@@ -98,6 +99,9 @@ type WorkerMessage_RegisteMessage struct {
type WorkerMessage_NodeInfo struct {
NodeInfo *NodeInfoResponse `protobuf:"bytes,10,opt,name=node_info,json=nodeInfo,proto3,oneof" json:"node_info,omitempty"`
}
type WorkerMessage_SubmitTaskAck struct {
SubmitTaskAck *SubmitTaskAck `protobuf:"bytes,11,opt,name=submit_task_ack,json=submitTaskAck,proto3,oneof" json:"submit_task_ack,omitempty"`
}
func (*WorkerMessage_HeartbeatResponse) isWorkerMessage_Message() {}
func (*WorkerMessage_SubmitTaskResult) isWorkerMessage_Message() {}
......@@ -109,6 +113,7 @@ func (*WorkerMessage_ResourceMap) isWorkerMessage_Message() {}
func (*WorkerMessage_FetchStandardTask) isWorkerMessage_Message() {}
func (*WorkerMessage_RegisteMessage) isWorkerMessage_Message() {}
func (*WorkerMessage_NodeInfo) isWorkerMessage_Message() {}
func (*WorkerMessage_SubmitTaskAck) isWorkerMessage_Message() {}
func (m *WorkerMessage) GetMessage() isWorkerMessage_Message {
if m != nil {
......@@ -187,6 +192,13 @@ func (m *WorkerMessage) GetNodeInfo() *NodeInfoResponse {
return nil
}
func (m *WorkerMessage) GetSubmitTaskAck() *SubmitTaskAck {
if x, ok := m.GetMessage().(*WorkerMessage_SubmitTaskAck); ok {
return x.SubmitTaskAck
}
return nil
}
// XXX_OneofWrappers is for the internal use of the proto package.
func (*WorkerMessage) XXX_OneofWrappers() []interface{} {
return []interface{}{
......@@ -200,6 +212,7 @@ func (*WorkerMessage) XXX_OneofWrappers() []interface{} {
(*WorkerMessage_FetchStandardTask)(nil),
(*WorkerMessage_RegisteMessage)(nil),
(*WorkerMessage_NodeInfo)(nil),
(*WorkerMessage_SubmitTaskAck)(nil),
}
}
......@@ -1035,6 +1048,44 @@ func (m *SubmitTaskResult) GetTaskExecuteError() string {
return ""
}
type SubmitTaskAck struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SubmitTaskAck) Reset() { *m = SubmitTaskAck{} }
func (m *SubmitTaskAck) String() string { return proto.CompactTextString(m) }
func (*SubmitTaskAck) ProtoMessage() {}
func (*SubmitTaskAck) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{17}
}
func (m *SubmitTaskAck) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SubmitTaskAck.Unmarshal(m, b)
}
func (m *SubmitTaskAck) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SubmitTaskAck.Marshal(b, m, deterministic)
}
func (m *SubmitTaskAck) XXX_Merge(src proto.Message) {
xxx_messageInfo_SubmitTaskAck.Merge(m, src)
}
func (m *SubmitTaskAck) XXX_Size() int {
return xxx_messageInfo_SubmitTaskAck.Size(m)
}
func (m *SubmitTaskAck) XXX_DiscardUnknown() {
xxx_messageInfo_SubmitTaskAck.DiscardUnknown(m)
}
var xxx_messageInfo_SubmitTaskAck proto.InternalMessageInfo
func (m *SubmitTaskAck) GetTaskId() string {
if m != nil {
return m.TaskId
}
return ""
}
type SubmitResourceMap struct {
ResourceMap []byte `protobuf:"bytes,1,opt,name=resource_map,json=resourceMap,proto3" json:"resource_map,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
......@@ -1046,7 +1097,7 @@ func (m *SubmitResourceMap) Reset() { *m = SubmitResourceMap{} }
func (m *SubmitResourceMap) String() string { return proto.CompactTextString(m) }
func (*SubmitResourceMap) ProtoMessage() {}
func (*SubmitResourceMap) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{17}
return fileDescriptor_810ae261dc8e2975, []int{18}
}
func (m *SubmitResourceMap) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SubmitResourceMap.Unmarshal(m, b)
......@@ -1088,7 +1139,7 @@ func (m *ProofTaskResult) Reset() { *m = ProofTaskResult{} }
func (m *ProofTaskResult) String() string { return proto.CompactTextString(m) }
func (*ProofTaskResult) ProtoMessage() {}
func (*ProofTaskResult) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{18}
return fileDescriptor_810ae261dc8e2975, []int{19}
}
func (m *ProofTaskResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProofTaskResult.Unmarshal(m, b)
......@@ -1154,7 +1205,7 @@ func (m *FetchStandardTask) Reset() { *m = FetchStandardTask{} }
func (m *FetchStandardTask) String() string { return proto.CompactTextString(m) }
func (*FetchStandardTask) ProtoMessage() {}
func (*FetchStandardTask) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{19}
return fileDescriptor_810ae261dc8e2975, []int{20}
}
func (m *FetchStandardTask) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FetchStandardTask.Unmarshal(m, b)
......@@ -1193,7 +1244,7 @@ func (m *DispatchTaskRequest) Reset() { *m = DispatchTaskRequest{} }
func (m *DispatchTaskRequest) String() string { return proto.CompactTextString(m) }
func (*DispatchTaskRequest) ProtoMessage() {}
func (*DispatchTaskRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{20}
return fileDescriptor_810ae261dc8e2975, []int{21}
}
func (m *DispatchTaskRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DispatchTaskRequest.Unmarshal(m, b)
......@@ -1239,7 +1290,7 @@ func (m *DispatchTaskResponse) Reset() { *m = DispatchTaskResponse{} }
func (m *DispatchTaskResponse) String() string { return proto.CompactTextString(m) }
func (*DispatchTaskResponse) ProtoMessage() {}
func (*DispatchTaskResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{21}
return fileDescriptor_810ae261dc8e2975, []int{22}
}
func (m *DispatchTaskResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DispatchTaskResponse.Unmarshal(m, b)
......@@ -1283,7 +1334,7 @@ func (m *ManagerListRequest) Reset() { *m = ManagerListRequest{} }
func (m *ManagerListRequest) String() string { return proto.CompactTextString(m) }
func (*ManagerListRequest) ProtoMessage() {}
func (*ManagerListRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{22}
return fileDescriptor_810ae261dc8e2975, []int{23}
}
func (m *ManagerListRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ManagerListRequest.Unmarshal(m, b)
......@@ -1314,7 +1365,7 @@ func (m *ManagerListResponse) Reset() { *m = ManagerListResponse{} }
func (m *ManagerListResponse) String() string { return proto.CompactTextString(m) }
func (*ManagerListResponse) ProtoMessage() {}
func (*ManagerListResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{23}
return fileDescriptor_810ae261dc8e2975, []int{24}
}
func (m *ManagerListResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ManagerListResponse.Unmarshal(m, b)
......@@ -1359,6 +1410,7 @@ func init() {
proto.RegisterType((*StatusResponse)(nil), "nodemanager.v1.StatusResponse")
proto.RegisterType((*PushTaskMessage)(nil), "nodemanager.v1.PushTaskMessage")
proto.RegisterType((*SubmitTaskResult)(nil), "nodemanager.v1.SubmitTaskResult")
proto.RegisterType((*SubmitTaskAck)(nil), "nodemanager.v1.SubmitTaskAck")
proto.RegisterType((*SubmitResourceMap)(nil), "nodemanager.v1.SubmitResourceMap")
proto.RegisterType((*ProofTaskResult)(nil), "nodemanager.v1.ProofTaskResult")
proto.RegisterType((*FetchStandardTask)(nil), "nodemanager.v1.FetchStandardTask")
......@@ -1373,90 +1425,92 @@ func init() {
}
var fileDescriptor_810ae261dc8e2975 = []byte{
// 1353 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x57, 0xcb, 0x72, 0x1b, 0x45,
0x14, 0x8d, 0x24, 0x3f, 0xa4, 0x6b, 0x5b, 0x8f, 0x96, 0x09, 0xc2, 0x21, 0xc4, 0x99, 0x14, 0x85,
0xc3, 0x43, 0x8a, 0xcc, 0xa3, 0xa8, 0x64, 0x41, 0xe1, 0x38, 0x89, 0x53, 0xe0, 0x44, 0x8c, 0x43,
0x48, 0x51, 0x29, 0x54, 0xad, 0xe9, 0xb6, 0x34, 0xe5, 0xcc, 0xf4, 0x30, 0xdd, 0x63, 0x50, 0xf1,
0x0f, 0x7c, 0x04, 0x4b, 0xf6, 0xec, 0xf8, 0x02, 0xaa, 0xd8, 0xf1, 0x05, 0x2c, 0xf9, 0x08, 0x8a,
0xea, 0xc7, 0x68, 0xa6, 0x47, 0xe3, 0xc0, 0x86, 0x9d, 0xe6, 0xf4, 0xe9, 0xd3, 0x7d, 0xfb, 0x9e,
0x7b, 0xbb, 0x05, 0x6f, 0x86, 0x8c, 0xd0, 0x00, 0x87, 0x78, 0x4a, 0xe3, 0xc1, 0xf9, 0x70, 0x10,
0xd3, 0x6f, 0x13, 0xca, 0xc5, 0x38, 0xa6, 0x3c, 0x62, 0x21, 0xa7, 0xfd, 0x28, 0x66, 0x82, 0xa1,
0x66, 0x8e, 0xd6, 0x3f, 0x1f, 0xee, 0xb4, 0x26, 0x98, 0xd3, 0xc1, 0x94, 0x4d, 0x99, 0x26, 0xec,
0x5c, 0x56, 0xc0, 0xf9, 0x70, 0xc0, 0xc8, 0x9c, 0x73, 0x9a, 0x70, 0x83, 0x5f, 0x5d, 0xd2, 0xe7,
0x2c, 0x89, 0x3d, 0xa3, 0xeb, 0xfc, 0xbd, 0x0a, 0x5b, 0x5f, 0xb1, 0xf8, 0x8c, 0xc6, 0xc7, 0x94,
0x73, 0x3c, 0xa5, 0xc8, 0x05, 0x34, 0xa3, 0x38, 0x16, 0x13, 0x8a, 0xb3, 0x5d, 0xf4, 0x2a, 0xbb,
0x95, 0xbd, 0x8d, 0xfd, 0xeb, 0x7d, 0x7b, 0x1b, 0xfd, 0xa3, 0x94, 0xe9, 0x1a, 0xe2, 0xd1, 0x25,
0xb7, 0x33, 0x2b, 0x82, 0x68, 0x04, 0x88, 0x27, 0x93, 0xc0, 0x17, 0x63, 0x81, 0xf9, 0x99, 0x54,
0x4d, 0x5e, 0x88, 0x5e, 0x55, 0x69, 0xee, 0x16, 0x35, 0x4f, 0x14, 0xf3, 0x09, 0xe6, 0x67, 0xae,
0xe2, 0x1d, 0x5d, 0x72, 0xdb, 0xbc, 0x80, 0xa1, 0x8f, 0x61, 0x8d, 0x0b, 0x2c, 0x12, 0xde, 0xab,
0x29, 0x95, 0x37, 0x96, 0x54, 0xd4, 0x68, 0x6e, 0x5b, 0x86, 0x8f, 0x0e, 0x61, 0x83, 0xd0, 0x73,
0xdf, 0xa3, 0x63, 0x3f, 0x3c, 0x65, 0xbd, 0x95, 0xf2, 0xc0, 0x0e, 0x15, 0xe5, 0x61, 0x78, 0xca,
0xcc, 0xb9, 0x1c, 0x5d, 0x72, 0x81, 0x2c, 0x40, 0x74, 0x04, 0x9b, 0x46, 0x25, 0x91, 0xa3, 0xbd,
0x55, 0x25, 0x73, 0xa3, 0x5c, 0xe6, 0x4b, 0x49, 0xc9, 0x6d, 0xc5, 0x6c, 0x40, 0xc1, 0xe8, 0x21,
0xb4, 0xa6, 0x8c, 0x91, 0xc9, 0x9c, 0x8e, 0x03, 0xbd, 0x54, 0x6f, 0xad, 0x3c, 0xa4, 0x07, 0x9a,
0x96, 0x6d, 0xa8, 0x39, 0xb5, 0x10, 0x74, 0x1f, 0x36, 0xd3, 0xf4, 0x8e, 0x03, 0x1c, 0xf5, 0xd6,
0xcb, 0x63, 0xd3, 0x07, 0xec, 0x1a, 0xe6, 0x31, 0x8e, 0xe4, 0x96, 0xe2, 0xec, 0x13, 0x9d, 0x40,
0xf7, 0x94, 0x0a, 0x6f, 0x36, 0xe6, 0x02, 0x87, 0x04, 0xc7, 0x44, 0xa5, 0xad, 0x57, 0x2f, 0x97,
0xbb, 0x2f, 0xa9, 0x27, 0x86, 0x29, 0x53, 0x24, 0x3d, 0x70, 0x5a, 0x04, 0x65, 0x9c, 0x31, 0x9d,
0xfa, 0x5c, 0x64, 0x71, 0x36, 0xca, 0xe3, 0x74, 0x35, 0x2d, 0x17, 0x67, 0x6c, 0x21, 0xe8, 0x13,
0x68, 0xc8, 0x29, 0x3a, 0x81, 0x50, 0xee, 0xa2, 0x47, 0x8c, 0xa8, 0x4c, 0xe5, 0x8e, 0xbd, 0x1e,
0x1a, 0xec, 0xa0, 0x01, 0xeb, 0x66, 0x0f, 0xce, 0x2f, 0x2b, 0xd0, 0x3c, 0xd6, 0xd3, 0x52, 0xf9,
0xc7, 0xd0, 0xc9, 0x57, 0x80, 0xaa, 0x47, 0x53, 0x00, 0xbb, 0x2f, 0x29, 0x00, 0xc5, 0x93, 0x66,
0x9d, 0x15, 0x30, 0x74, 0x0c, 0x9d, 0x28, 0xe1, 0x33, 0x6d, 0xfe, 0x34, 0x78, 0xed, 0xfe, 0x6b,
0x45, 0xc1, 0x51, 0xc2, 0x67, 0xf2, 0xbc, 0xb2, 0xe8, 0x5b, 0x91, 0x0d, 0x29, 0xb9, 0x98, 0xb1,
0x53, 0xab, 0x98, 0x6a, 0x17, 0xc8, 0x49, 0xa2, 0x55, 0x4b, 0xad, 0xc8, 0x86, 0xd0, 0x7d, 0x68,
0xea, 0xd2, 0x58, 0xc4, 0xaa, 0x6b, 0xe2, 0xea, 0x45, 0x25, 0x95, 0x06, 0xba, 0xc5, 0xf3, 0x00,
0x7a, 0x50, 0x5a, 0x12, 0xce, 0x4b, 0x4b, 0x22, 0x95, 0xfa, 0xbf, 0x2a, 0xe2, 0x18, 0x3a, 0x0b,
0xa7, 0x2c, 0xc2, 0x5b, 0x2f, 0x3f, 0xaa, 0xcc, 0x31, 0xe9, 0xae, 0x5a, 0xa1, 0x0d, 0xe5, 0x7d,
0xb3, 0x07, 0x4d, 0x7b, 0x75, 0x74, 0x19, 0xd6, 0x62, 0x8a, 0x39, 0x0b, 0x95, 0x57, 0x1a, 0xae,
0xf9, 0x72, 0x6e, 0x41, 0xbb, 0xe8, 0x12, 0xf4, 0x3a, 0x34, 0x84, 0x1f, 0x50, 0x2e, 0x70, 0x10,
0x29, 0xfa, 0x8a, 0x9b, 0x01, 0xce, 0x10, 0x3a, 0x4b, 0x8d, 0xf5, 0x5f, 0xa6, 0xb4, 0x60, 0xcb,
0x4a, 0x8f, 0xb3, 0x0d, 0x68, 0xf9, 0xa4, 0x9d, 0x23, 0xe8, 0x96, 0xb4, 0x24, 0x34, 0x84, 0x55,
0x9d, 0xb3, 0xca, 0x6e, 0x6d, 0x6f, 0x63, 0xff, 0xca, 0xcb, 0x72, 0xa6, 0x99, 0x4e, 0x17, 0x3a,
0x59, 0x8f, 0x4c, 0xe5, 0x45, 0x1e, 0x4c, 0xcf, 0xe5, 0x03, 0x58, 0xd7, 0xd9, 0x95, 0xbd, 0x5a,
0xca, 0xef, 0x5c, 0xdc, 0x6c, 0xdd, 0x94, 0x8a, 0x6e, 0x42, 0xdb, 0xb8, 0x89, 0xfb, 0xd3, 0x10,
0x8b, 0x24, 0xa6, 0xca, 0x97, 0x9b, 0x6e, 0x4b, 0xe3, 0x27, 0x29, 0xec, 0xcc, 0xa1, 0x69, 0xb7,
0x0c, 0x74, 0x05, 0x1a, 0x69, 0x8f, 0x8f, 0x4c, 0x36, 0xea, 0xa6, 0x79, 0x47, 0xe8, 0x3a, 0x6c,
0x06, 0x7e, 0x48, 0xe3, 0x71, 0x94, 0x4c, 0xce, 0xe8, 0x5c, 0x15, 0x62, 0xc3, 0xdd, 0x50, 0xd8,
0x48, 0x41, 0xe8, 0x2d, 0x68, 0x4d, 0x68, 0x48, 0x4f, 0x7d, 0x31, 0xc6, 0x84, 0xc4, 0x94, 0xeb,
0x6b, 0xa6, 0xe1, 0x36, 0x0d, 0xfc, 0xa9, 0x46, 0x9d, 0x0e, 0xb4, 0x0a, 0xb6, 0x71, 0x7e, 0x80,
0x76, 0xb1, 0xf7, 0x2c, 0x2d, 0x59, 0xf9, 0x4f, 0x4b, 0x56, 0xcb, 0x96, 0xb4, 0x63, 0xab, 0xd9,
0xb1, 0x39, 0x5f, 0xc0, 0x46, 0x2e, 0x57, 0xe8, 0xda, 0xe2, 0xae, 0x13, 0xf3, 0x88, 0x9a, 0x65,
0xcd, 0x35, 0xf6, 0x64, 0x1e, 0xa9, 0x8d, 0x59, 0x35, 0x5b, 0x55, 0xbe, 0xca, 0x57, 0xa3, 0xf3,
0x21, 0x34, 0xed, 0xbb, 0x14, 0xdd, 0x80, 0xad, 0x34, 0x35, 0xfa, 0x0a, 0xae, 0xa8, 0xbc, 0x18,
0x25, 0x4d, 0x76, 0x7e, 0xaf, 0x40, 0xab, 0xd0, 0xcb, 0xd0, 0xab, 0xb0, 0xae, 0x5a, 0x96, 0x4f,
0xd2, 0x12, 0x91, 0x9f, 0x0f, 0x09, 0xea, 0x43, 0x43, 0x0d, 0x9c, 0xf9, 0x21, 0x51, 0x7b, 0x68,
0xee, 0x77, 0xfa, 0xf2, 0x41, 0x23, 0xdd, 0x21, 0x15, 0x3e, 0xf3, 0x43, 0xe2, 0xd6, 0x85, 0xf9,
0x85, 0x76, 0xa0, 0xfe, 0x1d, 0x8b, 0xcf, 0x5e, 0x30, 0x4c, 0xd4, 0x11, 0xac, 0xb8, 0x8b, 0x6f,
0xf4, 0x1a, 0x28, 0xde, 0xd8, 0x0b, 0x88, 0x32, 0x4c, 0xc3, 0x55, 0x8b, 0xde, 0x0d, 0x08, 0xba,
0x0a, 0xa0, 0x86, 0x22, 0x1c, 0xe3, 0x40, 0xf5, 0xa7, 0x4d, 0x57, 0x2d, 0x3c, 0x92, 0x80, 0x3c,
0x59, 0x35, 0xac, 0xce, 0x6a, 0x4d, 0xcb, 0x4a, 0x40, 0x9e, 0x94, 0xf3, 0x63, 0x0d, 0xda, 0xc5,
0x97, 0xc9, 0xc5, 0x01, 0x0d, 0xa0, 0xeb, 0xb1, 0x50, 0x60, 0x95, 0xf4, 0xcc, 0xc0, 0x55, 0xb5,
0x24, 0x5a, 0x0c, 0x2d, 0x3c, 0x2c, 0xd3, 0x1f, 0x14, 0xc8, 0x35, 0x45, 0x6e, 0x06, 0x36, 0xf1,
0x5d, 0x40, 0xb9, 0xb6, 0x3f, 0x9e, 0x51, 0x4c, 0x68, 0x6c, 0x2a, 0xa3, 0x2d, 0xb2, 0x46, 0xaf,
0x70, 0xb4, 0x07, 0xed, 0x3c, 0x7b, 0xc2, 0xc8, 0xdc, 0xc4, 0xdd, 0xcc, 0xb8, 0x07, 0x8c, 0xcc,
0xa5, 0x13, 0x7c, 0x3e, 0xe6, 0x89, 0xe7, 0x51, 0xce, 0x29, 0x51, 0xf1, 0xd7, 0xdd, 0x0d, 0x9f,
0x9f, 0xa4, 0x10, 0xda, 0x87, 0x57, 0x94, 0x18, 0xfd, 0x9e, 0x7a, 0x89, 0xa0, 0x63, 0x92, 0xc4,
0x58, 0xf8, 0x2c, 0x54, 0x0d, 0x75, 0xc5, 0xed, 0xca, 0xc1, 0x7b, 0x7a, 0xec, 0xd0, 0x0c, 0xa1,
0xb7, 0xa1, 0x63, 0xcd, 0xf1, 0x18, 0xa1, 0xea, 0x21, 0xb1, 0xea, 0xb6, 0x72, 0xfc, 0xbb, 0x8c,
0x64, 0xa1, 0xa5, 0x5c, 0x1a, 0xc7, 0x2c, 0x56, 0x8f, 0x84, 0x86, 0x0e, 0xcd, 0x90, 0xef, 0x49,
0xdc, 0xf9, 0x08, 0x3a, 0x4b, 0x0f, 0x19, 0x19, 0x85, 0xf5, 0x02, 0xd2, 0xce, 0xcc, 0x3f, 0x6e,
0x9c, 0x5f, 0xa5, 0x31, 0x0b, 0x57, 0xe0, 0x85, 0x79, 0xcc, 0x1b, 0xad, 0x5a, 0x30, 0x9a, 0xd5,
0x90, 0x6b, 0x85, 0x86, 0x8c, 0xde, 0x81, 0x8e, 0xe9, 0x70, 0x4b, 0x0d, 0xac, 0x6d, 0x06, 0xb2,
0xa4, 0xde, 0x84, 0x76, 0x66, 0x17, 0xd3, 0x23, 0x74, 0x9a, 0x5a, 0x0b, 0x5c, 0xf7, 0x09, 0xe7,
0x16, 0x74, 0x96, 0x1e, 0x5c, 0xb6, 0x73, 0x2b, 0x05, 0xe7, 0x7e, 0x03, 0xdd, 0x43, 0x9f, 0x47,
0x58, 0x78, 0x33, 0x1d, 0xb2, 0xbe, 0x82, 0x86, 0x66, 0x0e, 0xc1, 0x02, 0x9b, 0xd7, 0xcd, 0xb6,
0x55, 0x73, 0x77, 0x59, 0x28, 0x68, 0x28, 0xb4, 0xd2, 0x21, 0x16, 0x18, 0x6d, 0xc3, 0xaa, 0x72,
0xa3, 0xe9, 0x4c, 0xfa, 0xc3, 0xb9, 0x07, 0xdb, 0xb6, 0xbe, 0x69, 0x13, 0x17, 0x1e, 0x6a, 0xb9,
0xcc, 0x36, 0x20, 0xf3, 0x0e, 0xfb, 0xdc, 0xe7, 0xe9, 0x45, 0xe9, 0xb8, 0xd0, 0xb5, 0x50, 0xa3,
0x7d, 0x07, 0xea, 0xe6, 0x10, 0xb9, 0xb9, 0xb3, 0x4a, 0xaf, 0x73, 0x33, 0x55, 0xf5, 0xe2, 0xc5,
0x84, 0x83, 0x3f, 0x2a, 0x80, 0x3c, 0x16, 0x14, 0x26, 0x1c, 0x6c, 0x9b, 0x35, 0xd3, 0x45, 0x46,
0xf2, 0x0f, 0xd2, 0xa8, 0xf2, 0xf5, 0xe3, 0xa9, 0x2f, 0x66, 0xc9, 0xa4, 0xef, 0xb1, 0x60, 0xf1,
0xe7, 0x6a, 0xf1, 0xe3, 0x3d, 0xf5, 0x37, 0xca, 0x63, 0x2f, 0x06, 0x53, 0x1a, 0x0e, 0xd4, 0xc7,
0x60, 0xca, 0x06, 0xf6, 0x9f, 0xae, 0x3b, 0xb9, 0xcf, 0xf3, 0xe1, 0x4f, 0xd5, 0xda, 0xa3, 0x67,
0xcf, 0x7e, 0xae, 0x36, 0x1f, 0xe5, 0xd6, 0x7f, 0x3a, 0xfc, 0xcd, 0x02, 0x9e, 0x3f, 0x1d, 0xfe,
0x59, 0xdd, 0xb1, 0x81, 0xe7, 0x0f, 0x46, 0x07, 0xc7, 0x54, 0x60, 0x99, 0xb1, 0xbf, 0xaa, 0xad,
0xdc, 0xe0, 0xed, 0xdb, 0x4f, 0x87, 0x93, 0x35, 0xb5, 0xfa, 0xfb, 0xff, 0x04, 0x00, 0x00, 0xff,
0xff, 0x63, 0x60, 0xb7, 0xc6, 0x52, 0x0e, 0x00, 0x00,
// 1385 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xb4, 0x57, 0x5d, 0x6f, 0x1b, 0x45,
0x17, 0xae, 0xed, 0x7c, 0xd8, 0xc7, 0x89, 0xd7, 0x1e, 0xe7, 0xed, 0x6b, 0x52, 0x4a, 0xd3, 0xad,
0x10, 0x29, 0x1f, 0x76, 0x1d, 0x3e, 0x84, 0xda, 0x0b, 0xd4, 0x34, 0x6d, 0x52, 0x41, 0x5a, 0xb3,
0x29, 0xa5, 0x42, 0x15, 0xd6, 0x78, 0x77, 0x62, 0xaf, 0xdc, 0xdd, 0x59, 0x76, 0x66, 0x03, 0x16,
0xff, 0x81, 0x1f, 0xc1, 0x25, 0xf7, 0xdc, 0x71, 0x8f, 0x84, 0xc4, 0x1d, 0xbf, 0x80, 0x4b, 0x7e,
0x05, 0x9a, 0x8f, 0xf5, 0xee, 0xac, 0xed, 0xc0, 0x0d, 0x77, 0xde, 0x67, 0x9e, 0x39, 0x33, 0xe7,
0x9c, 0xe7, 0x9c, 0x33, 0x86, 0x37, 0x43, 0xea, 0x91, 0x00, 0x87, 0x78, 0x4c, 0xe2, 0xde, 0x45,
0xbf, 0x17, 0x93, 0x6f, 0x12, 0xc2, 0xf8, 0x30, 0x26, 0x2c, 0xa2, 0x21, 0x23, 0xdd, 0x28, 0xa6,
0x9c, 0xa2, 0x46, 0x8e, 0xd6, 0xbd, 0xe8, 0xef, 0x5a, 0x23, 0xcc, 0x48, 0x6f, 0x4c, 0xc7, 0x54,
0x11, 0x76, 0xaf, 0x4a, 0xe0, 0xa2, 0xdf, 0xa3, 0xde, 0x8c, 0x31, 0x92, 0x30, 0x8d, 0x5f, 0x5f,
0xb0, 0xcf, 0x68, 0x12, 0xbb, 0xda, 0xae, 0xfd, 0xeb, 0x06, 0x6c, 0x7f, 0x49, 0xe3, 0x29, 0x89,
0x4f, 0x09, 0x63, 0x78, 0x4c, 0x90, 0x03, 0x68, 0x42, 0x70, 0xcc, 0x47, 0x04, 0x67, 0xb7, 0xe8,
0x94, 0xf6, 0x4a, 0xfb, 0xf5, 0x83, 0x9b, 0x5d, 0xf3, 0x1a, 0xdd, 0x93, 0x94, 0xe9, 0x68, 0xe2,
0xc9, 0x15, 0xa7, 0x35, 0x29, 0x82, 0x68, 0x00, 0x88, 0x25, 0xa3, 0xc0, 0xe7, 0x43, 0x8e, 0xd9,
0x54, 0x58, 0x4d, 0x5e, 0xf1, 0x4e, 0x59, 0xda, 0xdc, 0x2b, 0xda, 0x3c, 0x93, 0xcc, 0x67, 0x98,
0x4d, 0x1d, 0xc9, 0x3b, 0xb9, 0xe2, 0x34, 0x59, 0x01, 0x43, 0x1f, 0xc3, 0x06, 0xe3, 0x98, 0x27,
0xac, 0x53, 0x91, 0x56, 0xde, 0x58, 0xb0, 0x22, 0x57, 0x73, 0xd7, 0xd2, 0x7c, 0x74, 0x04, 0x75,
0x8f, 0x5c, 0xf8, 0x2e, 0x19, 0xfa, 0xe1, 0x39, 0xed, 0xac, 0x2d, 0x77, 0xec, 0x48, 0x52, 0x1e,
0x87, 0xe7, 0x54, 0xc7, 0xe5, 0xe4, 0x8a, 0x03, 0xde, 0x1c, 0x44, 0x27, 0xb0, 0xa5, 0xad, 0x24,
0x62, 0xb5, 0xb3, 0x2e, 0xcd, 0xdc, 0x5a, 0x6e, 0xe6, 0x0b, 0x41, 0xc9, 0x5d, 0x45, 0x5f, 0x40,
0xc2, 0xe8, 0x31, 0x58, 0x63, 0x4a, 0xbd, 0xd1, 0x8c, 0x0c, 0x03, 0x75, 0x54, 0x67, 0x63, 0xb9,
0x4b, 0xc7, 0x8a, 0x96, 0x5d, 0xa8, 0x31, 0x36, 0x10, 0xf4, 0x08, 0xb6, 0xd2, 0xf4, 0x0e, 0x03,
0x1c, 0x75, 0x36, 0x97, 0xfb, 0xa6, 0x02, 0xec, 0x68, 0xe6, 0x29, 0x8e, 0xc4, 0x95, 0xe2, 0xec,
0x13, 0x9d, 0x41, 0xfb, 0x9c, 0x70, 0x77, 0x32, 0x64, 0x1c, 0x87, 0x1e, 0x8e, 0x3d, 0x99, 0xb6,
0x4e, 0x75, 0xb9, 0xb9, 0x47, 0x82, 0x7a, 0xa6, 0x99, 0x22, 0x45, 0x42, 0x03, 0xe7, 0x45, 0x50,
0xf8, 0x19, 0x93, 0xb1, 0xcf, 0x78, 0xe6, 0x67, 0x6d, 0xb9, 0x9f, 0x8e, 0xa2, 0xe5, 0xfc, 0x8c,
0x0d, 0x04, 0x7d, 0x02, 0x35, 0xb1, 0x45, 0x25, 0x10, 0x96, 0xab, 0xe8, 0x09, 0xf5, 0x64, 0xa6,
0x72, 0x61, 0xaf, 0x86, 0x1a, 0x43, 0xc7, 0x60, 0xe5, 0xf5, 0x88, 0xdd, 0x69, 0xa7, 0x2e, 0xcd,
0x5c, 0x5f, 0x2d, 0xc6, 0xfb, 0xae, 0x70, 0x6c, 0x9b, 0xe5, 0x81, 0xc3, 0x1a, 0x6c, 0x6a, 0x67,
0xec, 0x9f, 0xd7, 0xa0, 0x71, 0xaa, 0x36, 0xa6, 0xf7, 0x7c, 0x0a, 0xad, 0x7c, 0x29, 0xc9, 0xc2,
0xd6, 0x95, 0xb4, 0x77, 0x49, 0x25, 0x49, 0x9e, 0x50, 0xfd, 0xa4, 0x80, 0xa1, 0x53, 0x68, 0x45,
0x09, 0x9b, 0xa8, 0x5b, 0xa7, 0x51, 0x54, 0x65, 0x74, 0xa3, 0x68, 0x70, 0x90, 0xb0, 0x89, 0xb8,
0x66, 0x16, 0x46, 0x2b, 0x32, 0x21, 0x69, 0x2e, 0xa6, 0xf4, 0xdc, 0xa8, 0xca, 0xca, 0x0a, 0x73,
0x82, 0x68, 0x14, 0xa5, 0x15, 0x99, 0x10, 0x7a, 0x04, 0x0d, 0x55, 0x63, 0x73, 0x5f, 0xd7, 0x56,
0x04, 0x55, 0xd7, 0x66, 0xea, 0xe8, 0x36, 0xcb, 0x03, 0xe8, 0x78, 0x69, 0x6d, 0xd9, 0x97, 0xd6,
0x56, 0x6a, 0xea, 0xbf, 0x2a, 0xad, 0x53, 0x68, 0xcd, 0x25, 0x37, 0x77, 0x6f, 0x73, 0x79, 0xa8,
0x32, 0xe9, 0xa5, 0xb7, 0xb2, 0x42, 0x13, 0xca, 0xeb, 0x66, 0x1f, 0x1a, 0xe6, 0xe9, 0xe8, 0x2a,
0x6c, 0xc4, 0x04, 0x33, 0x1a, 0x4a, 0xad, 0xd4, 0x1c, 0xfd, 0x65, 0xdf, 0x81, 0x66, 0x51, 0x25,
0xe8, 0x75, 0xa8, 0x71, 0x3f, 0x20, 0x8c, 0xe3, 0x20, 0x92, 0xf4, 0x35, 0x27, 0x03, 0xec, 0x3e,
0xb4, 0x16, 0x3a, 0xf4, 0x3f, 0x6c, 0xb1, 0x60, 0xdb, 0x48, 0x8f, 0xbd, 0x03, 0x68, 0x31, 0xd2,
0xf6, 0x09, 0xb4, 0x97, 0xf4, 0x36, 0xd4, 0x87, 0x75, 0x95, 0xb3, 0xd2, 0x5e, 0x65, 0xbf, 0x7e,
0x70, 0xed, 0xb2, 0x9c, 0x29, 0xa6, 0xdd, 0x86, 0x56, 0xd6, 0x6c, 0x53, 0xf3, 0x3c, 0x0f, 0xa6,
0x71, 0xf9, 0x00, 0x36, 0x55, 0x76, 0x45, 0xd3, 0x17, 0xe6, 0x77, 0x57, 0x77, 0x6d, 0x27, 0xa5,
0xa2, 0xdb, 0xd0, 0xd4, 0x6a, 0x62, 0xfe, 0x38, 0xc4, 0x3c, 0x89, 0x89, 0xd4, 0xe5, 0x96, 0x63,
0x29, 0xfc, 0x2c, 0x85, 0xed, 0x19, 0x34, 0xcc, 0xde, 0x83, 0xae, 0x41, 0x2d, 0x1d, 0x16, 0x91,
0xce, 0x46, 0x55, 0x4f, 0x81, 0x08, 0xdd, 0x84, 0xad, 0xc0, 0x0f, 0x49, 0x3c, 0x8c, 0x92, 0xd1,
0x94, 0xcc, 0x64, 0x21, 0xd6, 0x9c, 0xba, 0xc4, 0x06, 0x12, 0x42, 0x6f, 0x81, 0x35, 0x22, 0x21,
0x39, 0xf7, 0xf9, 0x10, 0x7b, 0x5e, 0x4c, 0x98, 0x9a, 0x57, 0x35, 0xa7, 0xa1, 0xe1, 0xfb, 0x0a,
0xb5, 0x5b, 0x60, 0x15, 0x64, 0x63, 0x7f, 0x0f, 0xcd, 0x62, 0x13, 0x5b, 0x38, 0xb2, 0xf4, 0xaf,
0x8e, 0x2c, 0x2f, 0x3b, 0xd2, 0xf4, 0xad, 0x62, 0xfa, 0x66, 0x7f, 0x0e, 0xf5, 0x5c, 0xae, 0xd0,
0x8d, 0xf9, 0xd0, 0xe4, 0xb3, 0x88, 0xe8, 0x63, 0xf5, 0x3c, 0x7c, 0x36, 0x8b, 0xe4, 0xc5, 0x8c,
0x9a, 0x2d, 0x4b, 0x5d, 0xe5, 0xab, 0xd1, 0xfe, 0x10, 0x1a, 0xe6, 0x50, 0x46, 0xb7, 0x60, 0x3b,
0x4d, 0x8d, 0x9a, 0xe5, 0x25, 0x99, 0x17, 0x6d, 0x49, 0x91, 0xed, 0xdf, 0x4b, 0x60, 0x15, 0x7a,
0x19, 0xfa, 0x3f, 0x6c, 0xca, 0x96, 0xe5, 0x7b, 0x69, 0x89, 0x88, 0xcf, 0xc7, 0x1e, 0xea, 0x42,
0x4d, 0x2e, 0x4c, 0xfd, 0xd0, 0x93, 0x77, 0x68, 0x1c, 0xb4, 0xba, 0xe2, 0x65, 0x24, 0xd4, 0x21,
0x2c, 0x7c, 0xea, 0x87, 0x9e, 0x53, 0xe5, 0xfa, 0x17, 0xda, 0x85, 0xea, 0xb7, 0x34, 0x9e, 0xbe,
0xa2, 0xd8, 0x93, 0x21, 0x58, 0x73, 0xe6, 0xdf, 0xe8, 0x35, 0x90, 0xbc, 0xa1, 0x1b, 0x78, 0x52,
0x30, 0x35, 0x47, 0x1e, 0xfa, 0x20, 0xf0, 0xd0, 0x75, 0x00, 0xb9, 0x14, 0xe1, 0x18, 0x07, 0xb2,
0x3f, 0x6d, 0x39, 0xf2, 0xe0, 0x81, 0x00, 0x44, 0x64, 0xe5, 0xb2, 0x8c, 0xd5, 0x86, 0x32, 0x2b,
0x00, 0x11, 0x29, 0xfb, 0x87, 0x0a, 0x34, 0x8b, 0x4f, 0x9c, 0xd5, 0x0e, 0xf5, 0xa0, 0xed, 0xd2,
0x90, 0x63, 0x99, 0xf4, 0x4c, 0xc0, 0x65, 0x79, 0x24, 0x9a, 0x2f, 0xcd, 0x35, 0x2c, 0xd2, 0x1f,
0x14, 0xc8, 0x15, 0x49, 0x6e, 0x04, 0x26, 0xf1, 0x5d, 0x40, 0xb9, 0xb6, 0x3f, 0x9c, 0x10, 0xec,
0x91, 0x58, 0x57, 0x46, 0x93, 0x67, 0x8d, 0x5e, 0xe2, 0x68, 0x1f, 0x9a, 0x79, 0xf6, 0x88, 0x7a,
0x33, 0xed, 0x77, 0x23, 0xe3, 0x1e, 0x52, 0x6f, 0x26, 0x94, 0xe0, 0xb3, 0x21, 0x4b, 0x5c, 0x97,
0x30, 0x46, 0x3c, 0xe9, 0x7f, 0xd5, 0xa9, 0xfb, 0xec, 0x2c, 0x85, 0xd0, 0x01, 0xfc, 0x4f, 0x1a,
0x23, 0xdf, 0x11, 0x37, 0xe1, 0x64, 0xe8, 0x25, 0x31, 0xe6, 0x3e, 0x0d, 0x65, 0x43, 0x5d, 0x73,
0xda, 0x62, 0xf1, 0xa1, 0x5a, 0x3b, 0xd2, 0x4b, 0xe8, 0x6d, 0x68, 0x19, 0x7b, 0x5c, 0xea, 0x11,
0xf9, 0x22, 0x59, 0x77, 0xac, 0x1c, 0xff, 0x01, 0xf5, 0x32, 0xd7, 0x52, 0x2e, 0x89, 0x63, 0x1a,
0xcb, 0xd7, 0x46, 0x4d, 0xb9, 0xa6, 0xc9, 0x0f, 0x05, 0x6e, 0xef, 0xc3, 0xb6, 0x31, 0xe5, 0x57,
0x26, 0xc3, 0xfe, 0x08, 0x5a, 0x0b, 0x6f, 0x27, 0xe1, 0xaf, 0xf1, 0xe8, 0x52, 0x1a, 0xce, 0xbf,
0xa7, 0xec, 0x5f, 0x84, 0x84, 0x0b, 0xc3, 0x72, 0x65, 0xc6, 0xf3, 0x92, 0x2c, 0x17, 0x24, 0x69,
0xb4, 0xee, 0x4a, 0xa1, 0x75, 0xa3, 0x77, 0xa0, 0xa5, 0x7b, 0xe1, 0x42, 0xab, 0x6b, 0xea, 0x85,
0x2c, 0xfd, 0xb7, 0xa1, 0x99, 0x09, 0x4b, 0x77, 0x13, 0x95, 0x50, 0x6b, 0x8e, 0xab, 0x8e, 0x62,
0xdf, 0x81, 0xd6, 0xc2, 0x1b, 0xcf, 0xd4, 0x78, 0xa9, 0xa0, 0xf1, 0xaf, 0xa1, 0x7d, 0xe4, 0xb3,
0x08, 0x73, 0x77, 0xa2, 0x5c, 0x56, 0xc3, 0xaa, 0xaf, 0xf7, 0x78, 0x98, 0x63, 0xfd, 0x0e, 0xda,
0x31, 0xaa, 0xf3, 0x01, 0x0d, 0x39, 0x09, 0xb9, 0xb2, 0x74, 0x84, 0x39, 0x46, 0x3b, 0xb0, 0x2e,
0x75, 0xab, 0x7b, 0x98, 0xfa, 0xb0, 0x1f, 0xc2, 0x8e, 0x69, 0x5f, 0x37, 0x94, 0x95, 0x41, 0x5d,
0x6e, 0x66, 0x07, 0x90, 0x7e, 0xb1, 0x7d, 0xe6, 0xb3, 0x74, 0xa4, 0xda, 0x0e, 0xb4, 0x0d, 0x54,
0xdb, 0xbe, 0x07, 0x55, 0x1d, 0x44, 0xa6, 0xa7, 0xdb, 0xd2, 0xc1, 0xaf, 0xb7, 0xca, 0xae, 0x3d,
0xdf, 0x70, 0xf8, 0x47, 0x09, 0x90, 0x4b, 0x83, 0xc2, 0x86, 0xc3, 0x1d, 0x7d, 0x66, 0x7a, 0xc8,
0x40, 0xfc, 0x27, 0x1b, 0x94, 0xbe, 0x7a, 0x3a, 0xf6, 0xf9, 0x24, 0x19, 0x75, 0x5d, 0x1a, 0xcc,
0xff, 0xcf, 0xcd, 0x7f, 0xbc, 0x27, 0xff, 0xb9, 0xb9, 0xf4, 0x55, 0x6f, 0x4c, 0xc2, 0x9e, 0xfc,
0xe8, 0x8d, 0x69, 0xcf, 0xfc, 0x9f, 0x77, 0x2f, 0xf7, 0x79, 0xd1, 0xff, 0xb1, 0x5c, 0x79, 0xf2,
0xe2, 0xc5, 0x4f, 0xe5, 0xc6, 0x93, 0xdc, 0xf9, 0xcf, 0xfb, 0xbf, 0x19, 0xc0, 0xcb, 0xe7, 0xfd,
0x3f, 0xcb, 0xbb, 0x26, 0xf0, 0xf2, 0x78, 0x70, 0x78, 0x4a, 0x38, 0x16, 0x19, 0xfb, 0xab, 0x6c,
0xe5, 0x16, 0xef, 0xde, 0x7d, 0xde, 0x1f, 0x6d, 0xc8, 0xd3, 0xdf, 0xff, 0x3b, 0x00, 0x00, 0xff,
0xff, 0x53, 0xb9, 0x6f, 0x86, 0xc5, 0x0e, 0x00, 0x00,
}
nodemanager/nodemanager/v1/request_response.proto
View file @ b896174b
......@@ -17,6 +17,7 @@ message WorkerMessage {
FetchStandardTask fetch_standard_task = 8;
RegisteMessage registe_message = 9;
NodeInfoResponse node_info = 10;
SubmitTaskAck submit_task_ack = 11;
}
}
......@@ -111,6 +112,10 @@ message SubmitTaskResult {
string task_execute_error = 9; // 任务执行错误信息
}
message SubmitTaskAck {
string task_id = 1;
}
message SubmitResourceMap {
bytes resource_map = 1; // a bitmap of all task id.
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment