Skip to content

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

add standard task

parent 3833d2e6
Hide whitespace changes
Inline Side-by-side
Showing with 141 additions and 81 deletions
gen/proto/go/nodemanager/v1/request_response.pb.go
View file @ ceb64402
...@@ -31,6 +31,7 @@ type WorkerMessage struct { ...@@ -31,6 +31,7 @@ type WorkerMessage struct {
// *WorkerMessage_DeviceUsage // *WorkerMessage_DeviceUsage
// *WorkerMessage_GoodbyeMessage // *WorkerMessage_GoodbyeMessage
// *WorkerMessage_ResourceMap // *WorkerMessage_ResourceMap
// *WorkerMessage_FetchStandardTask
Message isWorkerMessage_Message `protobuf_oneof:"message"` Message isWorkerMessage_Message `protobuf_oneof:"message"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
...@@ -86,6 +87,9 @@ type WorkerMessage_GoodbyeMessage struct { ...@@ -86,6 +87,9 @@ type WorkerMessage_GoodbyeMessage struct {
type WorkerMessage_ResourceMap struct { type WorkerMessage_ResourceMap struct {
ResourceMap *SubmitResourceMap `protobuf:"bytes,7,opt,name=resource_map,json=resourceMap,proto3,oneof" json:"resource_map,omitempty"` ResourceMap *SubmitResourceMap `protobuf:"bytes,7,opt,name=resource_map,json=resourceMap,proto3,oneof" json:"resource_map,omitempty"`
} }
type WorkerMessage_FetchStandardTask struct {
FetchStandardTask *FetchStandardTask `protobuf:"bytes,8,opt,name=fetch_standard_task,json=fetchStandardTask,proto3,oneof" json:"fetch_standard_task,omitempty"`
}
func (*WorkerMessage_HeartbeatResponse) isWorkerMessage_Message() {} func (*WorkerMessage_HeartbeatResponse) isWorkerMessage_Message() {}
func (*WorkerMessage_SubmitTaskResult) isWorkerMessage_Message() {} func (*WorkerMessage_SubmitTaskResult) isWorkerMessage_Message() {}
...@@ -94,6 +98,7 @@ func (*WorkerMessage_DeviceInfo) isWorkerMessage_Message() {} ...@@ -94,6 +98,7 @@ func (*WorkerMessage_DeviceInfo) isWorkerMessage_Message() {}
func (*WorkerMessage_DeviceUsage) isWorkerMessage_Message() {} func (*WorkerMessage_DeviceUsage) isWorkerMessage_Message() {}
func (*WorkerMessage_GoodbyeMessage) isWorkerMessage_Message() {} func (*WorkerMessage_GoodbyeMessage) isWorkerMessage_Message() {}
func (*WorkerMessage_ResourceMap) isWorkerMessage_Message() {} func (*WorkerMessage_ResourceMap) isWorkerMessage_Message() {}
func (*WorkerMessage_FetchStandardTask) isWorkerMessage_Message() {}
func (m *WorkerMessage) GetMessage() isWorkerMessage_Message { func (m *WorkerMessage) GetMessage() isWorkerMessage_Message {
if m != nil { if m != nil {
...@@ -151,6 +156,13 @@ func (m *WorkerMessage) GetResourceMap() *SubmitResourceMap { ...@@ -151,6 +156,13 @@ func (m *WorkerMessage) GetResourceMap() *SubmitResourceMap {
return nil return nil
} }
func (m *WorkerMessage) GetFetchStandardTask() *FetchStandardTask {
if x, ok := m.GetMessage().(*WorkerMessage_FetchStandardTask); ok {
return x.FetchStandardTask
}
return nil
}
// XXX_OneofWrappers is for the internal use of the proto package. // XXX_OneofWrappers is for the internal use of the proto package.
func (*WorkerMessage) XXX_OneofWrappers() []interface{} { func (*WorkerMessage) XXX_OneofWrappers() []interface{} {
return []interface{}{ return []interface{}{
...@@ -161,6 +173,7 @@ func (*WorkerMessage) XXX_OneofWrappers() []interface{} { ...@@ -161,6 +173,7 @@ func (*WorkerMessage) XXX_OneofWrappers() []interface{} {
(*WorkerMessage_DeviceUsage)(nil), (*WorkerMessage_DeviceUsage)(nil),
(*WorkerMessage_GoodbyeMessage)(nil), (*WorkerMessage_GoodbyeMessage)(nil),
(*WorkerMessage_ResourceMap)(nil), (*WorkerMessage_ResourceMap)(nil),
(*WorkerMessage_FetchStandardTask)(nil),
} }
} }
...@@ -966,6 +979,44 @@ func (m *ProofTaskResult) GetContainerPubkey() []byte { ...@@ -966,6 +979,44 @@ func (m *ProofTaskResult) GetContainerPubkey() []byte {
return nil return nil
} }
type FetchStandardTask struct {
TaskType uint64 `protobuf:"varint,1,opt,name=task_type,json=taskType,proto3" json:"task_type,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
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{16}
}
func (m *FetchStandardTask) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_FetchStandardTask.Unmarshal(m, b)
}
func (m *FetchStandardTask) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_FetchStandardTask.Marshal(b, m, deterministic)
}
func (m *FetchStandardTask) XXX_Merge(src proto.Message) {
xxx_messageInfo_FetchStandardTask.Merge(m, src)
}
func (m *FetchStandardTask) XXX_Size() int {
return xxx_messageInfo_FetchStandardTask.Size(m)
}
func (m *FetchStandardTask) XXX_DiscardUnknown() {
xxx_messageInfo_FetchStandardTask.DiscardUnknown(m)
}
var xxx_messageInfo_FetchStandardTask proto.InternalMessageInfo
func (m *FetchStandardTask) GetTaskType() uint64 {
if m != nil {
return m.TaskType
}
return 0
}
type DispatchTaskRequest struct { type DispatchTaskRequest struct {
TaskData *v1.TaskContent `protobuf:"bytes,1,opt,name=task_data,json=taskData,proto3" json:"task_data,omitempty"` TaskData *v1.TaskContent `protobuf:"bytes,1,opt,name=task_data,json=taskData,proto3" json:"task_data,omitempty"`
Miner string `protobuf:"bytes,2,opt,name=miner,proto3" json:"miner,omitempty"` Miner string `protobuf:"bytes,2,opt,name=miner,proto3" json:"miner,omitempty"`
...@@ -978,7 +1029,7 @@ func (m *DispatchTaskRequest) Reset() { *m = DispatchTaskRequest{} } ...@@ -978,7 +1029,7 @@ func (m *DispatchTaskRequest) Reset() { *m = DispatchTaskRequest{} }
func (m *DispatchTaskRequest) String() string { return proto.CompactTextString(m) } func (m *DispatchTaskRequest) String() string { return proto.CompactTextString(m) }
func (*DispatchTaskRequest) ProtoMessage() {} func (*DispatchTaskRequest) ProtoMessage() {}
func (*DispatchTaskRequest) Descriptor() ([]byte, []int) { func (*DispatchTaskRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{16} return fileDescriptor_810ae261dc8e2975, []int{17}
} }
func (m *DispatchTaskRequest) XXX_Unmarshal(b []byte) error { func (m *DispatchTaskRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DispatchTaskRequest.Unmarshal(m, b) return xxx_messageInfo_DispatchTaskRequest.Unmarshal(m, b)
...@@ -1024,7 +1075,7 @@ func (m *DispatchTaskResponse) Reset() { *m = DispatchTaskResponse{} } ...@@ -1024,7 +1075,7 @@ func (m *DispatchTaskResponse) Reset() { *m = DispatchTaskResponse{} }
func (m *DispatchTaskResponse) String() string { return proto.CompactTextString(m) } func (m *DispatchTaskResponse) String() string { return proto.CompactTextString(m) }
func (*DispatchTaskResponse) ProtoMessage() {} func (*DispatchTaskResponse) ProtoMessage() {}
func (*DispatchTaskResponse) Descriptor() ([]byte, []int) { func (*DispatchTaskResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{17} return fileDescriptor_810ae261dc8e2975, []int{18}
} }
func (m *DispatchTaskResponse) XXX_Unmarshal(b []byte) error { func (m *DispatchTaskResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_DispatchTaskResponse.Unmarshal(m, b) return xxx_messageInfo_DispatchTaskResponse.Unmarshal(m, b)
...@@ -1068,7 +1119,7 @@ func (m *ManagerListRequest) Reset() { *m = ManagerListRequest{} } ...@@ -1068,7 +1119,7 @@ func (m *ManagerListRequest) Reset() { *m = ManagerListRequest{} }
func (m *ManagerListRequest) String() string { return proto.CompactTextString(m) } func (m *ManagerListRequest) String() string { return proto.CompactTextString(m) }
func (*ManagerListRequest) ProtoMessage() {} func (*ManagerListRequest) ProtoMessage() {}
func (*ManagerListRequest) Descriptor() ([]byte, []int) { func (*ManagerListRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{18} return fileDescriptor_810ae261dc8e2975, []int{19}
} }
func (m *ManagerListRequest) XXX_Unmarshal(b []byte) error { func (m *ManagerListRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ManagerListRequest.Unmarshal(m, b) return xxx_messageInfo_ManagerListRequest.Unmarshal(m, b)
...@@ -1099,7 +1150,7 @@ func (m *ManagerListResponse) Reset() { *m = ManagerListResponse{} } ...@@ -1099,7 +1150,7 @@ func (m *ManagerListResponse) Reset() { *m = ManagerListResponse{} }
func (m *ManagerListResponse) String() string { return proto.CompactTextString(m) } func (m *ManagerListResponse) String() string { return proto.CompactTextString(m) }
func (*ManagerListResponse) ProtoMessage() {} func (*ManagerListResponse) ProtoMessage() {}
func (*ManagerListResponse) Descriptor() ([]byte, []int) { func (*ManagerListResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{19} return fileDescriptor_810ae261dc8e2975, []int{20}
} }
func (m *ManagerListResponse) XXX_Unmarshal(b []byte) error { func (m *ManagerListResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ManagerListResponse.Unmarshal(m, b) return xxx_messageInfo_ManagerListResponse.Unmarshal(m, b)
...@@ -1143,6 +1194,7 @@ func init() { ...@@ -1143,6 +1194,7 @@ func init() {
proto.RegisterType((*SubmitTaskResult)(nil), "nodemanager.v1.SubmitTaskResult") proto.RegisterType((*SubmitTaskResult)(nil), "nodemanager.v1.SubmitTaskResult")
proto.RegisterType((*SubmitResourceMap)(nil), "nodemanager.v1.SubmitResourceMap") proto.RegisterType((*SubmitResourceMap)(nil), "nodemanager.v1.SubmitResourceMap")
proto.RegisterType((*ProofTaskResult)(nil), "nodemanager.v1.ProofTaskResult") proto.RegisterType((*ProofTaskResult)(nil), "nodemanager.v1.ProofTaskResult")
proto.RegisterType((*FetchStandardTask)(nil), "nodemanager.v1.FetchStandardTask")
proto.RegisterType((*DispatchTaskRequest)(nil), "nodemanager.v1.DispatchTaskRequest") proto.RegisterType((*DispatchTaskRequest)(nil), "nodemanager.v1.DispatchTaskRequest")
proto.RegisterType((*DispatchTaskResponse)(nil), "nodemanager.v1.DispatchTaskResponse") proto.RegisterType((*DispatchTaskResponse)(nil), "nodemanager.v1.DispatchTaskResponse")
proto.RegisterType((*ManagerListRequest)(nil), "nodemanager.v1.ManagerListRequest") proto.RegisterType((*ManagerListRequest)(nil), "nodemanager.v1.ManagerListRequest")
...@@ -1154,81 +1206,84 @@ func init() { ...@@ -1154,81 +1206,84 @@ func init() {
} }
var fileDescriptor_810ae261dc8e2975 = []byte{ var fileDescriptor_810ae261dc8e2975 = []byte{
// 1209 bytes of a gzipped FileDescriptorProto // 1250 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0xdf, 0x72, 0xdb, 0xc4, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x9c, 0x56, 0xdd, 0x72, 0xdb, 0x44,
0x17, 0xae, 0xff, 0xc4, 0x89, 0x8f, 0x13, 0xd9, 0x5e, 0xfb, 0xd7, 0x9f, 0x49, 0x29, 0x4d, 0xd5, 0x14, 0xae, 0x7f, 0xe2, 0xc4, 0xc7, 0x89, 0x6c, 0xaf, 0x4d, 0x31, 0x29, 0xa5, 0xa9, 0x3a, 0x4c,
0x61, 0x9a, 0x0e, 0x60, 0xe3, 0xf0, 0x67, 0x98, 0xf6, 0x8a, 0x34, 0x69, 0x1c, 0x20, 0xa9, 0x51, 0xd3, 0x01, 0xec, 0x3a, 0xfc, 0x0c, 0xd3, 0x5e, 0x91, 0xa6, 0xad, 0x0b, 0x24, 0x35, 0x4a, 0x09,
0x4a, 0xe8, 0x30, 0x1d, 0x3c, 0x6b, 0x6b, 0x63, 0x6b, 0x1c, 0x69, 0x85, 0x76, 0x15, 0xf0, 0xcb, 0x1d, 0xa6, 0x83, 0x66, 0x2d, 0xad, 0x6d, 0x8d, 0x23, 0xad, 0xd0, 0xae, 0x02, 0x7e, 0x19, 0x2e,
0xf4, 0x82, 0x4b, 0x2e, 0x19, 0x9e, 0x82, 0x19, 0xee, 0x78, 0x00, 0x86, 0x4b, 0x9e, 0x82, 0xd1, 0xb8, 0xe4, 0x92, 0xe1, 0x29, 0x98, 0xe1, 0x8e, 0x07, 0x60, 0xb8, 0xe4, 0x96, 0x17, 0x60, 0xf6,
0xd9, 0x95, 0x2d, 0xc9, 0x4e, 0x3a, 0xc3, 0x9d, 0xf6, 0xdb, 0x6f, 0xbf, 0x3d, 0x7b, 0xce, 0xb7, 0x47, 0xb6, 0x24, 0x3b, 0xe9, 0x0c, 0x77, 0xda, 0x6f, 0xbf, 0xfd, 0x76, 0xf7, 0x9c, 0x6f, 0xcf,
0x67, 0x05, 0xef, 0x7a, 0xdc, 0x66, 0x2e, 0xf5, 0xe8, 0x98, 0x05, 0x9d, 0xab, 0x6e, 0x27, 0x60, 0x11, 0xbc, 0x1b, 0x50, 0x97, 0xf8, 0x38, 0xc0, 0x13, 0x12, 0xf5, 0x2e, 0xfa, 0xbd, 0x88, 0x7c,
0x3f, 0x84, 0x4c, 0xc8, 0x41, 0xc0, 0x84, 0xcf, 0x3d, 0xc1, 0xda, 0x7e, 0xc0, 0x25, 0x27, 0x46, 0x1f, 0x13, 0xc6, 0xed, 0x88, 0xb0, 0x90, 0x06, 0x8c, 0x74, 0xc3, 0x88, 0x72, 0x8a, 0x8c, 0x14,
0x82, 0xd6, 0xbe, 0xea, 0x6e, 0x57, 0x87, 0x54, 0xb0, 0xce, 0x98, 0x8f, 0xb9, 0x22, 0x6c, 0xdf, 0xad, 0x7b, 0xd1, 0xdf, 0xad, 0x8f, 0x30, 0x23, 0xbd, 0x09, 0x9d, 0x50, 0x45, 0xd8, 0xbd, 0x2e,
0x46, 0xe0, 0xaa, 0xdb, 0xe1, 0xf6, 0x4c, 0x08, 0x16, 0x0a, 0x8d, 0xdf, 0x5d, 0xd2, 0x17, 0x3c, 0x81, 0x8b, 0x7e, 0x8f, 0xba, 0x73, 0xc6, 0x48, 0xcc, 0x34, 0x7e, 0x73, 0x45, 0x9f, 0xd1, 0x38,
0x0c, 0x46, 0x5a, 0xd7, 0x7c, 0x5d, 0x84, 0xad, 0x6f, 0x79, 0x30, 0x65, 0xc1, 0x09, 0x13, 0x82, 0x72, 0xb4, 0xae, 0xf9, 0x6f, 0x19, 0x76, 0xbe, 0xa1, 0xd1, 0x8c, 0x44, 0xc7, 0x84, 0x31, 0x3c,
0x8e, 0x19, 0xb1, 0x80, 0x4c, 0x18, 0x0d, 0xe4, 0x90, 0xd1, 0x45, 0x14, 0xad, 0xdc, 0x4e, 0x6e, 0x21, 0xc8, 0x02, 0x34, 0x25, 0x38, 0xe2, 0x23, 0x82, 0x97, 0xa7, 0xe8, 0x14, 0xf6, 0x0a, 0xfb,
0xb7, 0xb2, 0x77, 0xbf, 0x9d, 0x0e, 0xa3, 0xdd, 0x8b, 0x99, 0x96, 0x26, 0xf6, 0x6e, 0x59, 0xf5, 0xb5, 0x83, 0xdb, 0xdd, 0xec, 0x31, 0xba, 0x83, 0x84, 0x69, 0x69, 0xe2, 0xe0, 0x9a, 0xd5, 0x9c,
0x49, 0x16, 0x24, 0x7d, 0x20, 0x22, 0x1c, 0xba, 0x8e, 0x1c, 0x48, 0x2a, 0xa6, 0x91, 0x6a, 0x78, 0xe6, 0x41, 0x34, 0x04, 0xc4, 0xe2, 0x91, 0xef, 0x71, 0x9b, 0x63, 0x36, 0x13, 0xaa, 0xf1, 0x39,
0x29, 0x5b, 0x79, 0xd4, 0xdc, 0xc9, 0x6a, 0x9e, 0x21, 0xf3, 0x05, 0x15, 0x53, 0x0b, 0x79, 0xbd, 0xef, 0x14, 0xa5, 0xe6, 0x5e, 0x5e, 0xf3, 0x54, 0x32, 0x5f, 0x60, 0x36, 0xb3, 0x24, 0x6f, 0x70,
0x5b, 0x56, 0x4d, 0x64, 0x30, 0xf2, 0x19, 0x94, 0x84, 0xa4, 0x32, 0x14, 0xad, 0x02, 0xaa, 0xbc, 0xcd, 0x6a, 0xb0, 0x1c, 0x86, 0x3e, 0x85, 0x0a, 0xe3, 0x98, 0xc7, 0xac, 0x53, 0x92, 0x2a, 0xef,
0xb3, 0xa4, 0x82, 0xb3, 0x89, 0xb0, 0x34, 0x9f, 0x1c, 0x42, 0xc5, 0x66, 0x57, 0xce, 0x88, 0x0d, 0xac, 0xa8, 0xc8, 0xd9, 0xd4, 0xb1, 0x34, 0x1f, 0x3d, 0x86, 0x9a, 0x4b, 0x2e, 0x3c, 0x87, 0xd8,
0x1c, 0xef, 0x82, 0xb7, 0x8a, 0xb8, 0xdc, 0xcc, 0x2e, 0x3f, 0x40, 0xca, 0xb1, 0x77, 0xc1, 0x13, 0x5e, 0x30, 0xa6, 0x9d, 0xb2, 0x5c, 0x6e, 0xe6, 0x97, 0x1f, 0x49, 0xca, 0xb3, 0x60, 0x4c, 0x53,
0x12, 0x60, 0xcf, 0x51, 0xd2, 0x83, 0x4d, 0x2d, 0x13, 0x46, 0x69, 0x6b, 0xad, 0xa1, 0xce, 0x83, 0x12, 0xe0, 0x2e, 0x50, 0x34, 0x80, 0x6d, 0x2d, 0x13, 0x8b, 0xb0, 0x75, 0x36, 0xa4, 0xce, 0x9d,
0xd5, 0x3a, 0xdf, 0x44, 0x94, 0x84, 0x90, 0x8e, 0x00, 0x61, 0x72, 0x0c, 0xd5, 0x31, 0xe7, 0xf6, 0xf5, 0x3a, 0x5f, 0x0b, 0x4a, 0x4a, 0x48, 0x9f, 0x40, 0xc2, 0xe8, 0x19, 0xd4, 0x27, 0x94, 0xba,
0x70, 0xc6, 0x06, 0xae, 0xaa, 0x41, 0xab, 0xb4, 0xfa, 0x4c, 0x47, 0x8a, 0xa6, 0x2b, 0xd5, 0xbb, 0xa3, 0x39, 0xb1, 0x7d, 0x95, 0x83, 0x4e, 0x65, 0xfd, 0x9d, 0x9e, 0x2a, 0x9a, 0xce, 0xd4, 0xe0,
0x65, 0x19, 0xe3, 0x14, 0x42, 0x9e, 0xc1, 0x66, 0x5c, 0xdf, 0x81, 0x4b, 0xfd, 0xd6, 0xfa, 0xea, 0x9a, 0x65, 0x4c, 0x32, 0x08, 0x7a, 0x02, 0xdb, 0x49, 0x7e, 0x6d, 0x1f, 0x87, 0x9d, 0xcd, 0xf5,
0xaa, 0xa9, 0x0c, 0x5b, 0x9a, 0x79, 0x42, 0xfd, 0x28, 0xa4, 0x60, 0x31, 0xdc, 0x2f, 0xc3, 0xba, 0x59, 0x53, 0x11, 0xb6, 0x34, 0xf3, 0x18, 0x87, 0xe2, 0x48, 0xd1, 0x72, 0x88, 0x4e, 0xa1, 0x35,
0x0e, 0xc5, 0xfc, 0xb5, 0x08, 0xc6, 0x89, 0x5a, 0x1a, 0xef, 0xf2, 0x1c, 0xea, 0x49, 0x87, 0xa0, 0x26, 0xdc, 0x99, 0xda, 0x8c, 0xe3, 0xc0, 0xc5, 0x91, 0x2b, 0xf3, 0xd6, 0xd9, 0x5a, 0x2f, 0xf7,
0x5f, 0xb5, 0x41, 0x76, 0x6e, 0x30, 0x08, 0xf2, 0xa2, 0x62, 0x4e, 0x32, 0x18, 0x39, 0x81, 0xba, 0x44, 0x50, 0x4f, 0x35, 0x53, 0xe4, 0x48, 0x98, 0x60, 0x9c, 0x07, 0x0f, 0xab, 0xb0, 0xa9, 0xef,
0x1f, 0x8a, 0x89, 0x32, 0x47, 0x9c, 0x03, 0xe5, 0x8e, 0x7b, 0x59, 0xc1, 0x7e, 0x28, 0x26, 0x91, 0x67, 0xfe, 0x5a, 0x06, 0xe3, 0x58, 0x09, 0x24, 0x47, 0x7f, 0x0e, 0xcd, 0xb4, 0xed, 0xe4, 0x23,
0x0f, 0x16, 0x49, 0xa8, 0xfa, 0x69, 0x08, 0xe5, 0x02, 0xce, 0x2f, 0x52, 0x66, 0x2b, 0x5c, 0x23, 0xd0, 0xae, 0xdb, 0xbb, 0xc2, 0x75, 0x92, 0x27, 0x1c, 0x32, 0xcd, 0x61, 0xe8, 0x18, 0x9a, 0x61,
0x17, 0x11, 0x53, 0x5e, 0xab, 0xfa, 0x69, 0x88, 0x3c, 0x03, 0x43, 0x59, 0x67, 0x7e, 0x56, 0xe5, 0xcc, 0xa6, 0xca, 0x71, 0x49, 0x60, 0x95, 0xe5, 0x6e, 0xe5, 0x05, 0x87, 0x31, 0x9b, 0x8a, 0x33,
0x99, 0xbb, 0xd7, 0x59, 0x2e, 0x3e, 0xe8, 0x96, 0x48, 0x02, 0xe4, 0x0b, 0x30, 0xb4, 0x63, 0x62, 0x2e, 0x23, 0x5b, 0x0f, 0xb3, 0x90, 0x94, 0x8b, 0x28, 0x1d, 0x67, 0x1c, 0x5c, 0xba, 0x44, 0x4e,
0x9d, 0xb5, 0xd5, 0xe5, 0x49, 0x7a, 0x6f, 0xae, 0xa5, 0x96, 0xc6, 0x5a, 0x47, 0x19, 0xf7, 0x95, 0x10, 0x33, 0x06, 0xae, 0x87, 0x59, 0x08, 0x3d, 0x01, 0x43, 0xf9, 0x71, 0x71, 0x57, 0x65, 0xc4,
0x6e, 0x72, 0xb1, 0x76, 0x5f, 0x2c, 0xf5, 0x26, 0xf3, 0xad, 0xff, 0x37, 0xf3, 0x25, 0x4d, 0xb3, 0x9b, 0x97, 0xf9, 0x38, 0xb9, 0xe8, 0x0e, 0x4b, 0x03, 0xe8, 0x73, 0x30, 0xb4, 0x0d, 0x13, 0x9d,
0x0b, 0x46, 0x9a, 0x4e, 0x6e, 0x43, 0x29, 0x60, 0x54, 0x70, 0x0f, 0x8d, 0x52, 0xb6, 0xf4, 0xc8, 0x8d, 0xf5, 0x49, 0x4a, 0x1b, 0x7a, 0xa1, 0xa5, 0x96, 0x26, 0x5a, 0x4f, 0x73, 0x96, 0xae, 0x5c,
0xfc, 0x10, 0x6a, 0x59, 0x8b, 0x90, 0xb7, 0xa1, 0x2c, 0x1d, 0x97, 0x09, 0x49, 0x5d, 0x1f, 0xe9, 0xf5, 0x34, 0xb4, 0xa5, 0x13, 0xa9, 0xd7, 0x39, 0x7a, 0xf3, 0xff, 0x39, 0x3a, 0x6d, 0x9a, 0x7d,
0x45, 0x6b, 0x01, 0x98, 0x5d, 0xa8, 0x2f, 0x75, 0x9d, 0x37, 0x2c, 0xa9, 0xc2, 0x56, 0xaa, 0x36, 0x30, 0xb2, 0x74, 0x74, 0x1d, 0x2a, 0x11, 0xc1, 0x8c, 0x06, 0xd2, 0x28, 0x55, 0x4b, 0x8f, 0xcc,
0x66, 0x13, 0xc8, 0x72, 0x6a, 0xcc, 0x1e, 0x34, 0x56, 0x5c, 0x57, 0xd2, 0x85, 0x35, 0x95, 0xe4, 0xfb, 0xd0, 0xc8, 0x5b, 0x04, 0xbd, 0x0d, 0x55, 0xee, 0xf9, 0x84, 0x71, 0xec, 0x87, 0x92, 0x5e,
0xdc, 0x4e, 0x61, 0xb7, 0xb2, 0x77, 0xe7, 0xa6, 0x24, 0x2b, 0xa6, 0xd9, 0x80, 0xfa, 0x52, 0x11, 0xb6, 0x96, 0x80, 0xd9, 0x87, 0xe6, 0x4a, 0x29, 0x7b, 0xcd, 0x92, 0x3a, 0xec, 0x64, 0x72, 0x63,
0xcd, 0xbf, 0x72, 0xf1, 0xae, 0xc9, 0xb6, 0x42, 0xee, 0xc3, 0xa6, 0xeb, 0x78, 0x2c, 0x18, 0xf8, 0xb6, 0x01, 0xad, 0x86, 0xc6, 0x1c, 0x40, 0x6b, 0x4d, 0x0d, 0x40, 0x7d, 0xd8, 0x50, 0x41, 0x2e,
0xe1, 0x70, 0xca, 0x66, 0x3a, 0x3f, 0x15, 0xc4, 0xfa, 0x08, 0x91, 0x87, 0x50, 0x1d, 0x32, 0x8f, 0xec, 0x95, 0xf6, 0x6b, 0x07, 0x37, 0xae, 0x0a, 0xb2, 0x62, 0x9a, 0x2d, 0x68, 0xae, 0x24, 0xd1,
0x5d, 0x38, 0x72, 0x40, 0x6d, 0x3b, 0x60, 0x42, 0xe0, 0xed, 0x28, 0x5b, 0x86, 0x86, 0x3f, 0x57, 0xfc, 0xab, 0x90, 0xec, 0x9a, 0xae, 0x55, 0xe8, 0x36, 0x6c, 0xfb, 0x5e, 0x40, 0x22, 0x3b, 0x8c,
0x28, 0xf9, 0x18, 0xd6, 0x55, 0x71, 0xa3, 0xb6, 0x18, 0x05, 0xbb, 0x7d, 0x83, 0xb7, 0x62, 0x2a, 0x47, 0x33, 0x32, 0xd7, 0xf1, 0xa9, 0x49, 0x6c, 0x28, 0x21, 0x74, 0x17, 0xea, 0x23, 0x12, 0x90,
0x79, 0x04, 0x35, 0x6d, 0x26, 0xe1, 0x8c, 0x3d, 0x2a, 0xc3, 0x80, 0xa1, 0xc5, 0x37, 0xad, 0xaa, 0xb1, 0xc7, 0x6d, 0xec, 0xba, 0x11, 0x61, 0x4c, 0xbe, 0x8e, 0xaa, 0x65, 0x68, 0xf8, 0x33, 0x85,
0xc2, 0xcf, 0x62, 0x98, 0xdc, 0x05, 0x88, 0x9b, 0xa7, 0x2f, 0x5a, 0x6b, 0x3b, 0x85, 0xdd, 0xb2, 0xa2, 0x8f, 0x60, 0x53, 0x25, 0x57, 0xd4, 0x5a, 0x71, 0xd8, 0xdd, 0x2b, 0xbc, 0x95, 0x50, 0xd1,
0x55, 0xd6, 0x5d, 0xd1, 0x17, 0xe6, 0xd7, 0x50, 0x49, 0x64, 0x83, 0xdc, 0x9b, 0xb7, 0x5a, 0x39, 0x3d, 0x68, 0x68, 0x33, 0x31, 0x6f, 0x12, 0x60, 0x1e, 0x47, 0x44, 0x5a, 0x7c, 0xdb, 0xaa, 0x2b,
0xf3, 0x99, 0x3e, 0x99, 0x16, 0x78, 0x31, 0xf3, 0xf1, 0xec, 0x29, 0x1b, 0xe7, 0xb1, 0x72, 0x49, 0xfc, 0x34, 0x81, 0xd1, 0x4d, 0x80, 0xa4, 0x22, 0x87, 0xac, 0xb3, 0xb1, 0x57, 0xda, 0xaf, 0x5a,
0x83, 0x9a, 0x9f, 0x80, 0x91, 0x6e, 0xe5, 0xe4, 0x01, 0x6c, 0xc5, 0xe1, 0xaa, 0x17, 0x20, 0x87, 0x55, 0x5d, 0x6a, 0x43, 0x66, 0x7e, 0x05, 0xb5, 0x54, 0x34, 0xd0, 0xad, 0x45, 0xfd, 0xe6, 0xf3,
0xb1, 0x6a, 0x25, 0x45, 0x36, 0xff, 0xc8, 0x41, 0x35, 0xd3, 0x2a, 0xc8, 0xff, 0x61, 0x1d, 0x3b, 0x90, 0xe8, 0x9b, 0x69, 0x81, 0x17, 0xf3, 0x50, 0xde, 0x3d, 0x63, 0xe3, 0xa2, 0xcc, 0x5c, 0xda,
0x82, 0x63, 0xc7, 0x26, 0x8c, 0x86, 0xc7, 0x36, 0x69, 0x43, 0x19, 0x27, 0xa6, 0x8e, 0x67, 0x63, 0xa0, 0xe6, 0xc7, 0x60, 0x64, 0xfb, 0x03, 0xba, 0x03, 0x3b, 0xc9, 0x71, 0x55, 0x5b, 0x29, 0xc8,
0x0c, 0xc6, 0x5e, 0xbd, 0x1d, 0xbd, 0xa7, 0x51, 0xc6, 0x22, 0x85, 0x2f, 0x1d, 0xcf, 0xb6, 0x36, 0xb3, 0x6a, 0x25, 0x45, 0x36, 0xff, 0x28, 0x40, 0x3d, 0x57, 0x2a, 0xd0, 0x9b, 0xb0, 0x29, 0x2b,
0xa4, 0xfe, 0x22, 0xdb, 0xb0, 0xf1, 0x23, 0x0f, 0xa6, 0x97, 0x9c, 0xda, 0xd8, 0x57, 0x8a, 0xd6, 0x82, 0xe7, 0x26, 0x26, 0x14, 0xc3, 0x67, 0x2e, 0xea, 0x42, 0x55, 0x4e, 0xcc, 0xbc, 0xc0, 0x95,
0x7c, 0x4c, 0xde, 0x02, 0xe4, 0x0d, 0x46, 0xae, 0x8d, 0x49, 0x2c, 0x5b, 0xb8, 0xe9, 0x53, 0xd7, 0x67, 0x30, 0x0e, 0x9a, 0x5d, 0xd1, 0xa4, 0x45, 0xc4, 0x84, 0xc2, 0x17, 0x5e, 0xe0, 0x5a, 0x5b,
0x8e, 0x92, 0x87, 0x53, 0x3e, 0x0d, 0xa8, 0x8b, 0x97, 0x7f, 0xd3, 0xc2, 0x8d, 0xfb, 0x11, 0x40, 0x5c, 0x7f, 0xa1, 0x5d, 0xd8, 0xfa, 0x81, 0x46, 0xb3, 0x73, 0x8a, 0x5d, 0x59, 0x57, 0xca, 0xd6,
0xee, 0xe8, 0x28, 0x30, 0x57, 0x25, 0x25, 0x1b, 0x01, 0x51, 0xa6, 0xcc, 0xdf, 0xf2, 0x50, 0xcb, 0x62, 0x8c, 0xde, 0x02, 0xc9, 0xb3, 0x1d, 0xdf, 0x95, 0x41, 0xac, 0x5a, 0x72, 0xd3, 0x47, 0xbe,
0x3e, 0x8c, 0xd7, 0x1f, 0xa8, 0x03, 0x8d, 0x11, 0xf7, 0x24, 0x45, 0x5f, 0x2d, 0x8a, 0x9a, 0xc7, 0x2b, 0x82, 0x27, 0xa7, 0x42, 0x1c, 0x61, 0x5f, 0x3e, 0xfe, 0x6d, 0x4b, 0x6e, 0x3c, 0x14, 0x00,
0x2d, 0xc9, 0x7c, 0x6a, 0x51, 0xd7, 0x87, 0x50, 0x75, 0x33, 0xe4, 0x02, 0x92, 0x0d, 0x37, 0x4d, 0xba, 0xa1, 0x4f, 0x21, 0x63, 0x55, 0x51, 0xb2, 0x02, 0x10, 0x91, 0x32, 0x7f, 0x2b, 0x42, 0x23,
0x7c, 0x1f, 0x48, 0xa2, 0xab, 0x0e, 0x26, 0x8c, 0xda, 0x2c, 0xd0, 0x6e, 0xa9, 0xc9, 0x45, 0x1f, 0xdf, 0x6d, 0x2f, 0xbf, 0x50, 0x0f, 0x5a, 0x0e, 0x0d, 0x38, 0x96, 0xbe, 0x5a, 0x26, 0xb5, 0x28,
0x45, 0x9c, 0xec, 0x42, 0x2d, 0xc9, 0x1e, 0x72, 0x7b, 0xa6, 0xcf, 0x6d, 0x2c, 0xb8, 0xfb, 0xdc, 0xb7, 0x44, 0x8b, 0xa9, 0x65, 0x5e, 0xef, 0x42, 0xdd, 0xcf, 0x91, 0x4b, 0x92, 0x6c, 0xf8, 0x59,
0x9e, 0x45, 0x4e, 0x70, 0xc4, 0x40, 0x84, 0xa3, 0x11, 0x13, 0x82, 0xd9, 0x78, 0xfe, 0x0d, 0xab, 0xe2, 0xfb, 0x80, 0x52, 0x55, 0xd5, 0x9e, 0x12, 0xec, 0x92, 0x48, 0xbb, 0xa5, 0xc1, 0x97, 0x75,
0xe2, 0x88, 0xb3, 0x18, 0x22, 0x7b, 0xf0, 0x3f, 0x14, 0x63, 0x3f, 0xb1, 0x51, 0x28, 0xd9, 0xc0, 0x54, 0xe2, 0x68, 0x1f, 0x1a, 0x69, 0xf6, 0x88, 0xba, 0x73, 0x7d, 0x6f, 0x63, 0xc9, 0x3d, 0xa4,
0x0e, 0x03, 0x2a, 0x1d, 0xee, 0x61, 0xc3, 0x2a, 0x5a, 0x8d, 0x68, 0xf2, 0x50, 0xcd, 0x1d, 0xe8, 0xee, 0x5c, 0x38, 0xc1, 0x63, 0x36, 0x8b, 0x1d, 0x87, 0x30, 0x46, 0x5c, 0x79, 0xff, 0x2d, 0xab,
0x29, 0xf3, 0x53, 0xa8, 0x2f, 0x3d, 0x76, 0xd1, 0x5e, 0xa9, 0x57, 0x52, 0xf9, 0x27, 0xf9, 0x00, 0xe6, 0xb1, 0xd3, 0x04, 0x42, 0x07, 0xf0, 0x86, 0x14, 0x23, 0x3f, 0x12, 0x27, 0xe6, 0xc4, 0x76,
0x9a, 0xaf, 0x23, 0xfb, 0x64, 0xde, 0x81, 0x6b, 0xb3, 0x9d, 0xb4, 0x43, 0x3e, 0x63, 0x87, 0xf7, 0xe3, 0x08, 0x73, 0x8f, 0x06, 0xb2, 0x60, 0x95, 0xad, 0x96, 0x98, 0x7c, 0xac, 0xe6, 0x8e, 0xf4,
0xa0, 0xae, 0x6f, 0xdf, 0x52, 0x6a, 0x6b, 0x7a, 0x62, 0x91, 0xdc, 0x47, 0x50, 0x5b, 0x94, 0x4d, 0x94, 0xf9, 0x09, 0x34, 0x57, 0x3a, 0xa8, 0xd8, 0x2b, 0xd3, 0x7a, 0x95, 0x7f, 0xd2, 0x5d, 0xd5,
0xb7, 0x03, 0x7d, 0x11, 0xe7, 0xb8, 0x6a, 0x09, 0xe6, 0xf7, 0xd0, 0x38, 0x70, 0x84, 0x4f, 0xe5, 0xfc, 0x49, 0xd8, 0x27, 0xd7, 0x07, 0x2e, 0x8d, 0x76, 0xda, 0x0e, 0xc5, 0x9c, 0x1d, 0xde, 0x83,
0x68, 0xa2, 0x42, 0x54, 0xad, 0xb3, 0xab, 0x3d, 0x64, 0x53, 0x49, 0xf5, 0x93, 0xdc, 0x4c, 0x39, 0xa6, 0x7e, 0x7d, 0x2b, 0xa1, 0x6d, 0xe8, 0x89, 0x65, 0x70, 0xef, 0x41, 0x63, 0x99, 0x36, 0x5d,
0xf9, 0x29, 0xf7, 0x24, 0xf3, 0xa4, 0x72, 0xd6, 0x01, 0x95, 0x94, 0x34, 0x61, 0x0d, 0x6b, 0xac, 0x0e, 0xf4, 0x43, 0x5c, 0xe0, 0xaa, 0x24, 0x98, 0xf7, 0xa1, 0xb9, 0xd2, 0xcb, 0xb3, 0x0e, 0x2a,
0x5b, 0x8a, 0x1a, 0x98, 0x87, 0xd0, 0x4c, 0xeb, 0xeb, 0xcb, 0x77, 0x6d, 0x12, 0x56, 0xcb, 0x34, 0xe4, 0x1c, 0xf4, 0x1d, 0xb4, 0x8e, 0x3c, 0x16, 0x62, 0xee, 0x4c, 0xd5, 0xa5, 0x54, 0xb1, 0xed,
0x81, 0xe8, 0x9f, 0x87, 0xaf, 0x1c, 0x11, 0x37, 0x78, 0xd3, 0x82, 0x46, 0x0a, 0xd5, 0xda, 0x4f, 0xeb, 0x35, 0x2e, 0xe6, 0x58, 0x37, 0xf1, 0x76, 0xc6, 0xfb, 0x8f, 0x68, 0xc0, 0x49, 0xc0, 0x95,
0x60, 0x43, 0xa7, 0x44, 0xe8, 0x5e, 0xbb, 0xf4, 0x5c, 0x9f, 0x72, 0x9b, 0xe9, 0xa5, 0xd8, 0xc3, 0xd2, 0x11, 0xe6, 0x18, 0xb5, 0x61, 0x43, 0xba, 0x42, 0x17, 0x21, 0x35, 0x30, 0x1f, 0x43, 0x3b,
0xe6, 0x0b, 0xf6, 0xff, 0xcc, 0x01, 0x19, 0x71, 0x37, 0xb3, 0x60, 0xbf, 0xa9, 0xf7, 0x8c, 0x37, 0xab, 0xaf, 0x9f, 0xeb, 0xa5, 0x61, 0x5b, 0x2f, 0xd3, 0x06, 0xa4, 0x7f, 0x37, 0xbe, 0xf4, 0x58,
0xe9, 0x47, 0x7f, 0xbd, 0xfd, 0xdc, 0x77, 0xcf, 0xc7, 0x8e, 0x9c, 0x84, 0xc3, 0xf6, 0x88, 0xbb, 0xd2, 0x12, 0x4c, 0x0b, 0x5a, 0x19, 0x54, 0x6b, 0x3f, 0x84, 0x2d, 0x1d, 0x44, 0xa6, 0xab, 0xf3,
0xf3, 0x3f, 0xe6, 0xf9, 0xc7, 0x07, 0xf8, 0x6f, 0x3c, 0xe2, 0x97, 0x9d, 0x31, 0xf3, 0x3a, 0x38, 0x4a, 0x83, 0x3f, 0xa1, 0x2e, 0xd1, 0x4b, 0x65, 0xd5, 0x5b, 0x2c, 0x38, 0xfc, 0xb3, 0x00, 0xc8,
0xe8, 0x8c, 0x79, 0x27, 0xfd, 0x27, 0xfd, 0x24, 0x31, 0xbc, 0xea, 0xfe, 0x9c, 0x2f, 0x9c, 0xbe, 0xa1, 0x7e, 0x6e, 0xc1, 0x61, 0x5b, 0xef, 0x99, 0x6c, 0x32, 0x14, 0x3f, 0xdf, 0xc3, 0xc2, 0xb7,
0x7c, 0xf9, 0x4b, 0xde, 0x38, 0x4d, 0xec, 0x7f, 0xde, 0xfd, 0x3d, 0x05, 0xbc, 0x3a, 0xef, 0xfe, 0xcf, 0x27, 0x1e, 0x9f, 0xc6, 0xa3, 0xae, 0x43, 0xfd, 0xc5, 0x8f, 0xfb, 0xe2, 0xe3, 0x03, 0xf9,
0x9d, 0xdf, 0x4e, 0x03, 0xaf, 0x8e, 0xfa, 0xfb, 0x27, 0x4c, 0xd2, 0xa8, 0x62, 0xff, 0xe4, 0xab, 0x8b, 0xee, 0xd0, 0xf3, 0xde, 0x84, 0x04, 0x3d, 0x39, 0xe8, 0x4d, 0x68, 0x2f, 0xfb, 0x43, 0xff,
0x89, 0xc9, 0xc7, 0x8f, 0xcf, 0xbb, 0xc3, 0x12, 0xee, 0xfe, 0xd1, 0xbf, 0x01, 0x00, 0x00, 0xff, 0x30, 0x35, 0xbc, 0xe8, 0xff, 0x5c, 0x2c, 0x9d, 0xbc, 0x7c, 0xf9, 0x4b, 0xd1, 0x38, 0x49, 0xed,
0xff, 0x16, 0xf8, 0xd0, 0xdb, 0x27, 0x0c, 0x00, 0x00, 0x7f, 0xd6, 0xff, 0x3d, 0x03, 0xbc, 0x3a, 0xeb, 0xff, 0x5d, 0xdc, 0xcd, 0x02, 0xaf, 0x9e, 0x0e,
0x0f, 0x8f, 0x09, 0xc7, 0x22, 0x63, 0xff, 0x14, 0xeb, 0xa9, 0xc9, 0x07, 0x0f, 0xce, 0xfa, 0xa3,
0x8a, 0xdc, 0xfd, 0xc3, 0xff, 0x02, 0x00, 0x00, 0xff, 0xff, 0x64, 0xad, 0xd6, 0x76, 0xae, 0x0c,
0x00, 0x00,
} }
nodemanager/nodemanager/v1/request_response.proto
View file @ ceb64402
...@@ -14,6 +14,7 @@ message WorkerMessage { ...@@ -14,6 +14,7 @@ message WorkerMessage {
DeviceUsageResponse device_usage = 5; DeviceUsageResponse device_usage = 5;
GoodbyeMessage goodbye_message = 6; GoodbyeMessage goodbye_message = 6;
SubmitResourceMap resource_map = 7; SubmitResourceMap resource_map = 7;
FetchStandardTask fetch_standard_task = 8;
} }
} }
...@@ -105,6 +106,10 @@ message ProofTaskResult { ...@@ -105,6 +106,10 @@ message ProofTaskResult {
bytes container_pubkey = 4; bytes container_pubkey = 4;
} }
message FetchStandardTask {
uint64 task_type = 1; // fetch a standard task with special task_type.
}
message DispatchTaskRequest { message DispatchTaskRequest {
base.v1.TaskContent task_data = 1; base.v1.TaskContent task_data = 1;
string miner = 2; string miner = 2;
......
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