Skip to content

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

add new message

parent 4dfca04c
Hide whitespace changes
Inline Side-by-side
Showing with 130 additions and 89 deletions
gen/proto/go/base/v1/odysseus.pb.go
View file @ 76bd2751
...@@ -210,19 +210,17 @@ func (*TaskContent) XXX_MessageName() string { ...@@ -210,19 +210,17 @@ func (*TaskContent) XXX_MessageName() string {
} }
// CREATE TABLE 'bills' ( // CREATE TABLE 'bills' (
// // id UUID,
// id UUID, // time TIMESTAMP,
// time TIMESTAMP, // type symbol CAPACITY 128 CACHE INDEX CAPACITY 8192,
// type symbol CAPACITY 128 CACHE INDEX CAPACITY 8192, // uid symbol CAPACITY 128 CACHE INDEX CAPACITY 8192,
// uid symbol CAPACITY 128 CACHE INDEX CAPACITY 8192, // fee INT,
// fee INT, // out_len INT,
// out_len INT, // workload INT,
// workload INT, // duration INT,
// duration INT, // profit_acc symbol CAPACITY 128 CACHE INDEX CAPACITY 8192,
// profit_acc symbol CAPACITY 128 CACHE INDEX CAPACITY 8192, // worker_acc symbol CAPACITY 128 CACHE INDEX CAPACITY 8192,
// worker_acc symbol CAPACITY 128 CACHE INDEX CAPACITY 8192, // result symbol CAPACITY 128 CACHE INDEX CAPACITY 8192
// result symbol CAPACITY 128 CACHE INDEX CAPACITY 8192
//
// ) timestamp (time) PARTITION BY DAY WAL; // ) timestamp (time) PARTITION BY DAY WAL;
type TaskReceipt struct { type TaskReceipt struct {
TaskUuid string `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"` TaskUuid string `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"`
......
gen/proto/go/nodemanager/v1/request_response.pb.go
View file @ 76bd2751
...@@ -24,7 +24,6 @@ const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package ...@@ -24,7 +24,6 @@ const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type WorkerMessage struct { type WorkerMessage struct {
// Types that are valid to be assigned to Message: // Types that are valid to be assigned to Message:
//
// *WorkerMessage_HeartbeatResponse // *WorkerMessage_HeartbeatResponse
// *WorkerMessage_SubmitTaskResult // *WorkerMessage_SubmitTaskResult
// *WorkerMessage_Status // *WorkerMessage_Status
...@@ -154,7 +153,6 @@ func (*WorkerMessage) XXX_OneofWrappers() []interface{} { ...@@ -154,7 +153,6 @@ func (*WorkerMessage) XXX_OneofWrappers() []interface{} {
type ManagerMessage struct { type ManagerMessage struct {
// Types that are valid to be assigned to Message: // Types that are valid to be assigned to Message:
//
// *ManagerMessage_HeartbeatRequest // *ManagerMessage_HeartbeatRequest
// *ManagerMessage_PushTaskMessage // *ManagerMessage_PushTaskMessage
// *ManagerMessage_ProofTaskResult // *ManagerMessage_ProofTaskResult
...@@ -823,6 +821,44 @@ func (m *SubmitTaskResult) GetIsSuccessed() bool { ...@@ -823,6 +821,44 @@ func (m *SubmitTaskResult) GetIsSuccessed() bool {
return false return false
} }
type SubmitResourceMap struct {
ResourceMap []byte `protobuf:"bytes,1,opt,name=resource_map,json=resourceMap,proto3" json:"resource_map,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
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{14}
}
func (m *SubmitResourceMap) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SubmitResourceMap.Unmarshal(m, b)
}
func (m *SubmitResourceMap) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SubmitResourceMap.Marshal(b, m, deterministic)
}
func (m *SubmitResourceMap) XXX_Merge(src proto.Message) {
xxx_messageInfo_SubmitResourceMap.Merge(m, src)
}
func (m *SubmitResourceMap) XXX_Size() int {
return xxx_messageInfo_SubmitResourceMap.Size(m)
}
func (m *SubmitResourceMap) XXX_DiscardUnknown() {
xxx_messageInfo_SubmitResourceMap.DiscardUnknown(m)
}
var xxx_messageInfo_SubmitResourceMap proto.InternalMessageInfo
func (m *SubmitResourceMap) GetResourceMap() []byte {
if m != nil {
return m.ResourceMap
}
return nil
}
type ProofTaskResult struct { type ProofTaskResult struct {
TaskUuid string `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"` TaskUuid string `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"`
Workload uint64 `protobuf:"varint,2,opt,name=workload,proto3" json:"workload,omitempty"` Workload uint64 `protobuf:"varint,2,opt,name=workload,proto3" json:"workload,omitempty"`
...@@ -837,7 +873,7 @@ func (m *ProofTaskResult) Reset() { *m = ProofTaskResult{} } ...@@ -837,7 +873,7 @@ func (m *ProofTaskResult) Reset() { *m = ProofTaskResult{} }
func (m *ProofTaskResult) String() string { return proto.CompactTextString(m) } func (m *ProofTaskResult) String() string { return proto.CompactTextString(m) }
func (*ProofTaskResult) ProtoMessage() {} func (*ProofTaskResult) ProtoMessage() {}
func (*ProofTaskResult) Descriptor() ([]byte, []int) { func (*ProofTaskResult) Descriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{14} return fileDescriptor_810ae261dc8e2975, []int{15}
} }
func (m *ProofTaskResult) XXX_Unmarshal(b []byte) error { func (m *ProofTaskResult) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProofTaskResult.Unmarshal(m, b) return xxx_messageInfo_ProofTaskResult.Unmarshal(m, b)
...@@ -897,7 +933,7 @@ func (m *DispatchTaskRequest) Reset() { *m = DispatchTaskRequest{} } ...@@ -897,7 +933,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{15} return fileDescriptor_810ae261dc8e2975, []int{16}
} }
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)
...@@ -943,7 +979,7 @@ func (m *DispatchTaskResponse) Reset() { *m = DispatchTaskResponse{} } ...@@ -943,7 +979,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{16} return fileDescriptor_810ae261dc8e2975, []int{17}
} }
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)
...@@ -987,7 +1023,7 @@ func (m *ManagerListRequest) Reset() { *m = ManagerListRequest{} } ...@@ -987,7 +1023,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{17} return fileDescriptor_810ae261dc8e2975, []int{18}
} }
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)
...@@ -1018,7 +1054,7 @@ func (m *ManagerListResponse) Reset() { *m = ManagerListResponse{} } ...@@ -1018,7 +1054,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{18} return fileDescriptor_810ae261dc8e2975, []int{19}
} }
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)
...@@ -1060,6 +1096,7 @@ func init() { ...@@ -1060,6 +1096,7 @@ func init() {
proto.RegisterType((*StatusResponse)(nil), "nodemanager.v1.StatusResponse") proto.RegisterType((*StatusResponse)(nil), "nodemanager.v1.StatusResponse")
proto.RegisterType((*PushTaskMessage)(nil), "nodemanager.v1.PushTaskMessage") proto.RegisterType((*PushTaskMessage)(nil), "nodemanager.v1.PushTaskMessage")
proto.RegisterType((*SubmitTaskResult)(nil), "nodemanager.v1.SubmitTaskResult") proto.RegisterType((*SubmitTaskResult)(nil), "nodemanager.v1.SubmitTaskResult")
proto.RegisterType((*SubmitResourceMap)(nil), "nodemanager.v1.SubmitResourceMap")
proto.RegisterType((*ProofTaskResult)(nil), "nodemanager.v1.ProofTaskResult") proto.RegisterType((*ProofTaskResult)(nil), "nodemanager.v1.ProofTaskResult")
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")
...@@ -1072,73 +1109,75 @@ func init() { ...@@ -1072,73 +1109,75 @@ func init() {
} }
var fileDescriptor_810ae261dc8e2975 = []byte{ var fileDescriptor_810ae261dc8e2975 = []byte{
// 1083 bytes of a gzipped FileDescriptorProto // 1107 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0x5f, 0x6f, 0xe3, 0xc4, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xdd, 0x6e, 0xe3, 0x44,
0x17, 0x6d, 0x92, 0xfe, 0xcb, 0x4d, 0xeb, 0x24, 0xd3, 0x68, 0x95, 0x5f, 0xf7, 0x57, 0xda, 0x7a, 0x14, 0xde, 0x24, 0xfd, 0xcb, 0x49, 0xeb, 0x24, 0xd3, 0x68, 0x15, 0xba, 0x94, 0xb6, 0x5e, 0x21,
0x85, 0xe8, 0x0a, 0x91, 0x90, 0x02, 0x12, 0xda, 0x7d, 0xa2, 0x5b, 0x68, 0x8a, 0x68, 0x37, 0xb8, 0xba, 0x42, 0x24, 0xa4, 0xfc, 0x08, 0xed, 0x5e, 0xd1, 0x2d, 0x34, 0x45, 0xb4, 0x1b, 0xdc, 0xdd,
0xbb, 0x65, 0x85, 0x56, 0x44, 0x93, 0x78, 0x9a, 0x58, 0xad, 0x3d, 0xc6, 0x33, 0x2e, 0xea, 0xd7, 0xb2, 0x42, 0x2b, 0xa2, 0x49, 0x3c, 0x4d, 0xac, 0xd6, 0x1e, 0xe3, 0x19, 0x17, 0xf5, 0x75, 0xf6,
0xd9, 0x47, 0x1e, 0x11, 0x5f, 0x80, 0x57, 0x24, 0xde, 0x10, 0x1f, 0x80, 0x47, 0x3e, 0x05, 0x9a, 0x92, 0x4b, 0xc4, 0x0b, 0x70, 0x8b, 0xc4, 0x1d, 0xe2, 0x01, 0xb8, 0xe4, 0x29, 0xd0, 0x9c, 0x19,
0x3b, 0x63, 0xc7, 0x76, 0xba, 0xd9, 0x07, 0xde, 0xe2, 0xe3, 0x3b, 0x67, 0xce, 0xdc, 0x73, 0xe6, 0x3b, 0xb6, 0xd3, 0xcd, 0x5e, 0x70, 0xe7, 0xf9, 0xe6, 0x9b, 0x6f, 0xce, 0x9c, 0xef, 0xcc, 0xf1,
0x3a, 0xf0, 0x7e, 0xc0, 0x5d, 0xe6, 0xd3, 0x80, 0x4e, 0x58, 0xd4, 0xbd, 0xed, 0x75, 0x23, 0xf6, 0xc0, 0xfb, 0x01, 0x77, 0x99, 0x4f, 0x03, 0x3a, 0x61, 0x51, 0xf7, 0xa6, 0xd7, 0x8d, 0xd8, 0x4f,
0x63, 0xcc, 0x84, 0x1c, 0x46, 0x4c, 0x84, 0x3c, 0x10, 0xac, 0x13, 0x46, 0x5c, 0x72, 0x62, 0x65, 0x31, 0x13, 0x72, 0x18, 0x31, 0x11, 0xf2, 0x40, 0xb0, 0x4e, 0x18, 0x71, 0xc9, 0x89, 0x95, 0xa1,
0xca, 0x3a, 0xb7, 0xbd, 0xed, 0xfa, 0x88, 0x0a, 0xd6, 0x9d, 0xf0, 0x09, 0xd7, 0x05, 0xdb, 0x0f, 0x75, 0x6e, 0x7a, 0x5b, 0xf5, 0x11, 0x15, 0xac, 0x3b, 0xe1, 0x13, 0xae, 0x09, 0x5b, 0xf7, 0x11,
0x10, 0xb8, 0xed, 0x75, 0xb9, 0x7b, 0x27, 0x04, 0x8b, 0x85, 0xc1, 0x77, 0xe6, 0xf8, 0x05, 0x8f, 0xb8, 0xe9, 0x75, 0xb9, 0x7b, 0x2b, 0x04, 0x8b, 0x85, 0xc1, 0xb7, 0xe7, 0xf4, 0x05, 0x8f, 0xa3,
0xa3, 0xb1, 0xe1, 0xb5, 0xff, 0xaa, 0xc0, 0xe6, 0x77, 0x3c, 0xba, 0x66, 0xd1, 0x19, 0x13, 0x82, 0xb1, 0xd1, 0xb5, 0xff, 0xae, 0xc0, 0xc6, 0xf7, 0x3c, 0xba, 0x62, 0xd1, 0x29, 0x13, 0x82, 0x4e,
0x4e, 0x18, 0x71, 0x80, 0x4c, 0x19, 0x8d, 0xe4, 0x88, 0xd1, 0x99, 0x8a, 0x76, 0x69, 0xaf, 0x74, 0x18, 0x71, 0x80, 0x4c, 0x19, 0x8d, 0xe4, 0x88, 0xd1, 0x59, 0x14, 0xed, 0xd2, 0x6e, 0x69, 0xbf,
0x50, 0x3b, 0xdc, 0xef, 0xe4, 0x65, 0x74, 0xfa, 0x49, 0xa5, 0x63, 0x0a, 0xfb, 0x4b, 0x4e, 0x73, 0x76, 0xb0, 0xd7, 0xc9, 0x87, 0xd1, 0xe9, 0x27, 0x4c, 0xc7, 0x10, 0xfb, 0xf7, 0x9c, 0xe6, 0xb4,
0x5a, 0x04, 0xc9, 0x00, 0x88, 0x88, 0x47, 0xbe, 0x27, 0x87, 0x92, 0x8a, 0x6b, 0xc5, 0x1a, 0xdf, 0x08, 0x92, 0x01, 0x10, 0x11, 0x8f, 0x7c, 0x4f, 0x0e, 0x25, 0x15, 0x57, 0x4a, 0x35, 0xbe, 0x96,
0xc8, 0x76, 0x19, 0x39, 0xf7, 0x8a, 0x9c, 0x17, 0x58, 0xf9, 0x82, 0x8a, 0x6b, 0x07, 0xeb, 0xfa, 0xed, 0x32, 0x6a, 0xee, 0x16, 0x35, 0xcf, 0x91, 0xf9, 0x9c, 0x8a, 0x2b, 0x07, 0x79, 0xfd, 0x7b,
0x4b, 0x4e, 0x43, 0x14, 0x30, 0xf2, 0x39, 0xac, 0x0a, 0x49, 0x65, 0x2c, 0xda, 0x15, 0x64, 0x79, 0x4e, 0x43, 0x14, 0x30, 0xf2, 0x05, 0xac, 0x08, 0x49, 0x65, 0x2c, 0xda, 0x15, 0x54, 0x79, 0x6f,
0x6f, 0x8e, 0x05, 0xdf, 0x66, 0x64, 0x99, 0x7a, 0xf2, 0x25, 0xd4, 0x5c, 0x76, 0xeb, 0x8d, 0xd9, 0x4e, 0x05, 0x67, 0x33, 0x61, 0x19, 0x3e, 0xf9, 0x0a, 0x6a, 0x2e, 0xbb, 0xf1, 0xc6, 0x6c, 0xe8,
0xd0, 0x0b, 0xae, 0x78, 0x7b, 0x19, 0x97, 0xdb, 0xc5, 0xe5, 0xc7, 0x58, 0x72, 0x1a, 0x5c, 0xf1, 0x05, 0x97, 0xbc, 0xbd, 0x84, 0xcb, 0xed, 0xe2, 0xf2, 0x23, 0xa4, 0x9c, 0x04, 0x97, 0x3c, 0x23,
0x0c, 0x05, 0xb8, 0x29, 0x4a, 0xfa, 0xb0, 0x61, 0x68, 0x62, 0xd5, 0xb6, 0xf6, 0x0a, 0xf2, 0x3c, 0x01, 0x6e, 0x8a, 0x92, 0x3e, 0xac, 0x1b, 0x99, 0x58, 0xa5, 0xad, 0xbd, 0x8c, 0x3a, 0x0f, 0xef,
0xba, 0x9f, 0xe7, 0xa5, 0x2a, 0xc9, 0x10, 0x19, 0x05, 0x08, 0x93, 0x53, 0xa8, 0x4f, 0x38, 0x77, 0xd6, 0x79, 0xa1, 0x28, 0x19, 0x21, 0x13, 0x01, 0xc2, 0xe4, 0x04, 0xea, 0x13, 0xce, 0xdd, 0xd1,
0x47, 0x77, 0x6c, 0xe8, 0x6b, 0x0f, 0xda, 0xab, 0xf7, 0x9f, 0xe9, 0x44, 0x97, 0x19, 0xa7, 0xfa, 0x2d, 0x1b, 0xfa, 0xda, 0x83, 0xf6, 0xca, 0xdd, 0x67, 0x3a, 0xd6, 0x34, 0xe3, 0x54, 0xff, 0x9e,
0x4b, 0x8e, 0x35, 0xc9, 0x21, 0x47, 0x55, 0x58, 0x33, 0x14, 0xf6, 0x2f, 0xcb, 0x60, 0x9d, 0xe9, 0x63, 0x4d, 0x72, 0xc8, 0x61, 0x15, 0x56, 0x8d, 0x84, 0xfd, 0xeb, 0x12, 0x58, 0xa7, 0x7a, 0x69,
0xa5, 0x89, 0xb3, 0xcf, 0xa1, 0x99, 0x75, 0x16, 0x73, 0x66, 0x8c, 0xdd, 0x5b, 0x60, 0x2c, 0xd6, 0xe2, 0xec, 0x33, 0x68, 0x66, 0x9d, 0xc5, 0x3a, 0x33, 0xc6, 0xee, 0x2e, 0x30, 0x16, 0x79, 0xca,
0x29, 0x13, 0xa6, 0x05, 0x8c, 0x9c, 0x41, 0x33, 0x8c, 0xc5, 0x54, 0x9b, 0x9a, 0x68, 0xd7, 0xae, 0x84, 0x69, 0x01, 0x23, 0xa7, 0xd0, 0x0c, 0x63, 0x31, 0xd5, 0xa6, 0x26, 0xb1, 0x6b, 0x57, 0x77,
0xee, 0x16, 0x09, 0x07, 0xb1, 0x98, 0x2a, 0xff, 0x66, 0xe2, 0xeb, 0x61, 0x1e, 0x42, 0xba, 0x88, 0x8a, 0x82, 0x83, 0x58, 0x4c, 0x95, 0x7f, 0xb3, 0xe0, 0xeb, 0x61, 0x1e, 0x42, 0xb9, 0x88, 0xf3,
0xf3, 0xab, 0x5c, 0x48, 0x2a, 0x6f, 0xa1, 0x53, 0x85, 0xb9, 0x8c, 0xd4, 0xc3, 0x3c, 0x44, 0xbe, 0xcb, 0x5c, 0x91, 0x54, 0xde, 0x20, 0xa7, 0x88, 0xb9, 0x1a, 0xa9, 0x87, 0x79, 0x88, 0x7c, 0x0d,
0x02, 0x4b, 0x5b, 0x9e, 0x9e, 0x55, 0x7b, 0xbd, 0xf3, 0xb6, 0xa8, 0x24, 0x07, 0xdd, 0x14, 0x59, 0x96, 0xb6, 0x3c, 0x3d, 0xab, 0xf6, 0x7a, 0xfb, 0x4d, 0xa5, 0x92, 0x1c, 0x74, 0x43, 0x64, 0x01,
0x80, 0x7c, 0x0d, 0x96, 0x71, 0x3a, 0xe1, 0x59, 0xb9, 0xff, 0x32, 0x64, 0x33, 0x93, 0x72, 0xe9, 0xf2, 0x0d, 0x58, 0xc6, 0xe9, 0x44, 0x67, 0xf9, 0xee, 0xcb, 0x90, 0xad, 0x99, 0x54, 0x4b, 0x2f,
0xa5, 0x09, 0xd7, 0x49, 0x21, 0x35, 0xab, 0x8b, 0xd2, 0x67, 0x52, 0x93, 0x50, 0xbd, 0x2b, 0x34, 0x4d, 0xb4, 0x8e, 0x0b, 0x55, 0xb3, 0xb2, 0xa8, 0xfa, 0x4c, 0xd5, 0x24, 0x52, 0x6f, 0x2b, 0x9a,
0x6b, 0xff, 0x3d, 0x34, 0x07, 0x60, 0xe5, 0xcb, 0xc9, 0x03, 0x58, 0x8d, 0x18, 0x15, 0x3c, 0xc0, 0xd5, 0xff, 0x5f, 0x34, 0xfb, 0x60, 0xe5, 0xe9, 0xe4, 0x3e, 0xac, 0x44, 0x8c, 0x0a, 0x1e, 0x60,
0xa0, 0x54, 0x1d, 0xf3, 0x64, 0x7f, 0x0c, 0x8d, 0x62, 0x44, 0xc8, 0xff, 0xa1, 0x2a, 0x3d, 0x9f, 0xa1, 0x54, 0x1d, 0x33, 0xb2, 0x3f, 0x86, 0x46, 0xb1, 0x44, 0xc8, 0xbb, 0x50, 0x95, 0x9e, 0xcf,
0x09, 0x49, 0xfd, 0x10, 0xcb, 0x97, 0x9d, 0x19, 0x60, 0xf7, 0xa0, 0x39, 0x37, 0x2d, 0xde, 0xb1, 0x84, 0xa4, 0x7e, 0x88, 0xf4, 0x25, 0x67, 0x06, 0xd8, 0x3d, 0x68, 0xce, 0x75, 0x8b, 0xb7, 0x2c,
0xa4, 0x0e, 0x9b, 0x39, 0x6f, 0xec, 0x16, 0x90, 0xf9, 0xd6, 0xd8, 0x7d, 0xd8, 0xba, 0xe7, 0x9a, 0xa9, 0xc3, 0x46, 0xce, 0x1b, 0xbb, 0x05, 0x64, 0x3e, 0x35, 0x76, 0x1f, 0x36, 0xef, 0xb8, 0x66,
0x91, 0x1e, 0xac, 0xe8, 0x26, 0x97, 0xf6, 0x2a, 0x07, 0xb5, 0xc3, 0x87, 0x8b, 0x9a, 0xac, 0x2b, 0xa4, 0x07, 0xcb, 0x3a, 0xc9, 0xa5, 0xdd, 0xca, 0x7e, 0xed, 0xe0, 0xc1, 0xa2, 0x24, 0x6b, 0xa6,
0xed, 0x2d, 0x68, 0xce, 0x99, 0x68, 0xff, 0x56, 0x4a, 0x76, 0xcd, 0x8e, 0x03, 0xb2, 0x0f, 0x1b, 0xbd, 0x09, 0xcd, 0x39, 0x13, 0xed, 0xdf, 0x4b, 0xc9, 0xae, 0xd9, 0x76, 0x40, 0xf6, 0x60, 0xdd,
0xbe, 0x17, 0xb0, 0x68, 0x18, 0xc6, 0xa3, 0x6b, 0x76, 0x67, 0xfa, 0x53, 0x43, 0x6c, 0x80, 0x10, 0xf7, 0x02, 0x16, 0x0d, 0xc3, 0x78, 0x74, 0xc5, 0x6e, 0x4d, 0x7e, 0x6a, 0x88, 0x0d, 0x10, 0x22,
0xf9, 0x00, 0xea, 0x23, 0x16, 0xb0, 0x2b, 0x4f, 0x0e, 0xa9, 0xeb, 0x46, 0x4c, 0x08, 0xbc, 0x1d, 0x1f, 0x40, 0x7d, 0xc4, 0x02, 0x76, 0xe9, 0xc9, 0x21, 0x75, 0xdd, 0x88, 0x09, 0x81, 0xb7, 0xa3,
0x55, 0xc7, 0x32, 0xf0, 0x17, 0x1a, 0x25, 0x9f, 0xc2, 0x9a, 0x36, 0x57, 0x8d, 0x33, 0x25, 0x76, 0xea, 0x58, 0x06, 0xfe, 0x52, 0xa3, 0xe4, 0x53, 0x58, 0xd5, 0xe6, 0xaa, 0x76, 0xa6, 0x82, 0xdd,
0x7b, 0x41, 0xb6, 0x92, 0x52, 0xf2, 0x18, 0x1a, 0x26, 0x4c, 0xc2, 0x9b, 0x04, 0x54, 0xc6, 0x11, 0x5a, 0x50, 0x5b, 0x09, 0x95, 0x3c, 0x82, 0x86, 0x29, 0x26, 0xe1, 0x4d, 0x02, 0x2a, 0xe3, 0x88,
0xc3, 0x88, 0x6f, 0x38, 0x75, 0x8d, 0x5f, 0x24, 0xb0, 0xfd, 0x2d, 0xd4, 0x32, 0xc7, 0x25, 0xbb, 0x61, 0x89, 0xaf, 0x3b, 0x75, 0x8d, 0x9f, 0x27, 0xb0, 0xfd, 0x1d, 0xd4, 0x32, 0xc7, 0x25, 0x3b,
0xe9, 0x0c, 0x94, 0x77, 0x21, 0x33, 0xd2, 0xcd, 0x74, 0x7b, 0x71, 0x17, 0xe2, 0xe1, 0x72, 0x39, 0x69, 0x0f, 0x94, 0xb7, 0x21, 0x33, 0xa1, 0x9b, 0xee, 0xf6, 0xfc, 0x36, 0xc4, 0xc3, 0xe5, 0xea,
0x2d, 0xa3, 0x35, 0xd9, 0x04, 0xda, 0x9f, 0x81, 0x95, 0x9f, 0xb1, 0xe4, 0x11, 0x6c, 0x26, 0x7a, 0xb4, 0x8c, 0xd6, 0x64, 0x2b, 0xd0, 0xfe, 0x0c, 0xac, 0x7c, 0x8f, 0x25, 0x0f, 0x61, 0x23, 0x89,
0xf4, 0x68, 0x2e, 0xa1, 0x18, 0xc3, 0xa4, 0x8b, 0xed, 0x5f, 0x4b, 0x50, 0x2f, 0xcc, 0x02, 0xf2, 0x47, 0xb7, 0xe6, 0x12, 0x06, 0x63, 0x94, 0x34, 0xd9, 0xfe, 0xad, 0x04, 0xf5, 0x42, 0x2f, 0x20,
0x10, 0xaa, 0x78, 0xe5, 0xe3, 0xd8, 0x73, 0x8d, 0x98, 0x75, 0x05, 0xbc, 0x8c, 0x3d, 0x97, 0x74, 0x0f, 0xa0, 0x8a, 0x57, 0x3e, 0x8e, 0x3d, 0xd7, 0x04, 0xb3, 0xa6, 0x80, 0x17, 0xb1, 0xe7, 0x92,
0xcc, 0x4b, 0x54, 0xaa, 0x74, 0x58, 0x87, 0xcd, 0x8e, 0xfa, 0xd8, 0xa9, 0xb6, 0x28, 0x16, 0x25, 0x8e, 0x99, 0xc4, 0x48, 0x55, 0x1c, 0xd6, 0x41, 0xb3, 0xa3, 0x7e, 0x76, 0x2a, 0x2d, 0x4a, 0x45,
0x58, 0xd7, 0xa3, 0xf4, 0x6d, 0x58, 0xff, 0x89, 0x47, 0xd7, 0x37, 0x9c, 0xba, 0x38, 0x3c, 0x96, 0x05, 0xac, 0xf9, 0x18, 0xfa, 0x16, 0xac, 0xfd, 0xcc, 0xa3, 0xab, 0x6b, 0x4e, 0x5d, 0x6c, 0x1e,
0x9d, 0xf4, 0x99, 0xfc, 0x0f, 0xb0, 0x6e, 0x38, 0xf6, 0x5d, 0xec, 0x54, 0xd5, 0x59, 0x53, 0xcf, 0x4b, 0x4e, 0x3a, 0x26, 0xef, 0x00, 0xf2, 0x86, 0x63, 0xdf, 0xc5, 0x4c, 0x55, 0x9d, 0x55, 0x35,
0xcf, 0x7c, 0x97, 0xec, 0x00, 0xe0, 0xab, 0x90, 0x46, 0xd4, 0xc7, 0x1b, 0xbe, 0xe1, 0xe0, 0xc6, 0x7e, 0xea, 0xbb, 0x64, 0x1b, 0x00, 0xa7, 0x42, 0x1a, 0x51, 0x1f, 0x6f, 0xf8, 0xba, 0x83, 0x1b,
0x03, 0x05, 0xd8, 0x7f, 0x94, 0xa0, 0x51, 0xfc, 0x30, 0x2d, 0xd6, 0xdd, 0x85, 0xad, 0x31, 0x0f, 0x0f, 0x14, 0x60, 0xff, 0x59, 0x82, 0x46, 0xf1, 0xc7, 0xb4, 0x38, 0xee, 0x2e, 0x6c, 0x8e, 0x79,
0x24, 0xc5, 0x8c, 0xcc, 0x0c, 0x2a, 0x23, 0x33, 0x49, 0x5f, 0xa5, 0x1e, 0xa9, 0xb4, 0xf8, 0x85, 0x20, 0x29, 0xd6, 0xc8, 0xcc, 0xa0, 0x32, 0x2a, 0x93, 0x74, 0x2a, 0xf5, 0x48, 0x55, 0x8b, 0x5f,
0xe2, 0x0a, 0x16, 0x5b, 0x7e, 0xbe, 0x70, 0x17, 0x6a, 0xd9, 0x09, 0xa9, 0x2d, 0x47, 0xf5, 0x46, 0x20, 0x57, 0x90, 0x6c, 0xf9, 0x79, 0xe2, 0x0e, 0xd4, 0xb2, 0x1d, 0x52, 0x5b, 0x8e, 0xd1, 0x9b,
0xd7, 0x3e, 0x6c, 0x78, 0x62, 0x28, 0xe2, 0xf1, 0x98, 0x09, 0xc1, 0x5c, 0x3c, 0xcd, 0xba, 0x53, 0xb8, 0xf6, 0x60, 0xdd, 0x13, 0x43, 0x11, 0x8f, 0xc7, 0x4c, 0x08, 0xe6, 0xe2, 0x69, 0xd6, 0x9c,
0xf3, 0xc4, 0x45, 0x02, 0xd9, 0x6f, 0x94, 0x0d, 0x85, 0x81, 0xb9, 0xf0, 0x38, 0xd9, 0xb6, 0x96, 0x9a, 0x27, 0xce, 0x13, 0xc8, 0xfe, 0x1c, 0x9a, 0xfa, 0x38, 0x8e, 0x79, 0x0f, 0x9c, 0xd2, 0x50,
0x0b, 0x6d, 0xfd, 0x10, 0x9a, 0x26, 0xaa, 0x73, 0xda, 0x1b, 0xe6, 0xc5, 0x4c, 0xfd, 0x63, 0x68, 0xad, 0x4b, 0x9e, 0x07, 0x43, 0x9f, 0x86, 0xc6, 0xbf, 0x5a, 0x34, 0xa3, 0xd8, 0xaf, 0x95, 0x7d,
0xcc, 0xfa, 0x62, 0xee, 0x8e, 0x49, 0x6d, 0x8a, 0xeb, 0xfb, 0x63, 0xff, 0x00, 0x5b, 0xc7, 0x9e, 0x85, 0x46, 0xbb, 0x30, 0x0d, 0x59, 0x3b, 0xca, 0x05, 0x3b, 0x3e, 0x84, 0xa6, 0x29, 0xf1, 0xb9,
0x08, 0xa9, 0x1c, 0x4f, 0xb5, 0x4c, 0x3d, 0x67, 0x7a, 0x46, 0xa7, 0x4b, 0x25, 0x35, 0xdf, 0xaf, 0x33, 0x37, 0xcc, 0xc4, 0xec, 0xd4, 0x8f, 0xa0, 0x31, 0xcb, 0xa7, 0xb9, 0x73, 0xa6, 0xda, 0x53,
0x56, 0x2e, 0x11, 0xcf, 0x78, 0x20, 0x59, 0x20, 0xb5, 0xfa, 0x63, 0x2a, 0x29, 0x69, 0xc1, 0x0a, 0x5c, 0xdf, 0x3b, 0xfb, 0x47, 0xd8, 0x3c, 0xf2, 0x44, 0x48, 0xe5, 0x78, 0xaa, 0xc3, 0xd4, 0xfd,
0x36, 0xd1, 0xdc, 0x3f, 0xfd, 0x60, 0x9f, 0x42, 0x2b, 0xcf, 0x6f, 0x82, 0xbc, 0xb0, 0x11, 0xf7, 0xa9, 0x67, 0xe2, 0x74, 0xa9, 0xa4, 0xe6, 0xbf, 0xd7, 0xca, 0x55, 0xd2, 0x53, 0x1e, 0x48, 0x16,
0x53, 0xb5, 0x80, 0x98, 0xaf, 0xed, 0x37, 0x9e, 0x48, 0x26, 0xa2, 0xed, 0xc0, 0x56, 0x0e, 0x35, 0x48, 0x1d, 0xfd, 0x11, 0x95, 0x94, 0xb4, 0x60, 0x19, 0x93, 0x6f, 0xee, 0xad, 0x1e, 0xd8, 0x27,
0xfc, 0x4f, 0x61, 0xdd, 0xb4, 0x45, 0x98, 0xe1, 0x34, 0xf7, 0x7d, 0x3b, 0xe7, 0x2e, 0x33, 0x4b, 0xd0, 0xca, 0xeb, 0x9b, 0x0b, 0xb0, 0x30, 0x11, 0x77, 0x4b, 0xb5, 0x80, 0x98, 0xbf, 0xf4, 0xb7,
0xf1, 0xd2, 0xa7, 0x0b, 0x8e, 0xfe, 0x2c, 0x01, 0x19, 0x73, 0xbf, 0xb0, 0xe0, 0xa8, 0x65, 0xf6, 0x9e, 0x48, 0x3a, 0xa9, 0xed, 0xc0, 0x66, 0x0e, 0x35, 0xfa, 0x4f, 0x60, 0xcd, 0xa4, 0x45, 0x98,
0x4c, 0x36, 0x19, 0xa8, 0xbf, 0x77, 0x83, 0xd2, 0xf7, 0xcf, 0x27, 0x9e, 0x9c, 0xc6, 0xa3, 0xce, 0xa6, 0x36, 0xf7, 0x5f, 0x3c, 0xe3, 0x2e, 0x33, 0x4b, 0xb1, 0x59, 0xa4, 0x0b, 0x0e, 0xff, 0x2a,
0x98, 0xfb, 0xe9, 0x5f, 0xc3, 0xf4, 0xc7, 0x47, 0xf8, 0x27, 0x70, 0xcc, 0x6f, 0xba, 0x13, 0x16, 0x01, 0x19, 0x73, 0xbf, 0xb0, 0xe0, 0xb0, 0x65, 0xf6, 0x4c, 0x36, 0x19, 0xa8, 0x67, 0xe1, 0xa0,
0x74, 0xf1, 0xa1, 0x3b, 0xe1, 0xdd, 0xfc, 0x5f, 0xc6, 0xa7, 0x99, 0xc7, 0xdb, 0xde, 0x9b, 0x72, 0xf4, 0xc3, 0xb3, 0x89, 0x27, 0xa7, 0xf1, 0xa8, 0x33, 0xe6, 0x7e, 0xfa, 0xa4, 0x4c, 0x3f, 0x3e,
0xe5, 0xfc, 0xd5, 0xab, 0x9f, 0xcb, 0xd6, 0x79, 0x66, 0xff, 0xcb, 0xde, 0xef, 0x39, 0xe0, 0xf5, 0xc2, 0xc7, 0xe3, 0x98, 0x5f, 0x77, 0x27, 0x2c, 0xe8, 0xe2, 0xa0, 0x3b, 0xe1, 0xdd, 0xfc, 0x53,
0x65, 0xef, 0xef, 0xf2, 0x76, 0x1e, 0x78, 0x7d, 0x32, 0x38, 0x3a, 0x63, 0x92, 0x2a, 0xd7, 0xfe, 0xf3, 0x49, 0x66, 0x78, 0xd3, 0x7b, 0x5d, 0xae, 0x9c, 0xbd, 0x7c, 0xf9, 0x4b, 0xd9, 0x3a, 0xcb,
0x29, 0xd7, 0x33, 0x2f, 0x9f, 0x3c, 0xb9, 0xec, 0x8d, 0x56, 0x71, 0xf7, 0x4f, 0xfe, 0x0d, 0x00, 0xec, 0x7f, 0xd1, 0xfb, 0x23, 0x07, 0xbc, 0xba, 0xe8, 0xfd, 0x53, 0xde, 0xca, 0x03, 0xaf, 0x8e,
0x00, 0xff, 0xff, 0x64, 0xad, 0xa4, 0x27, 0x10, 0x0b, 0x00, 0x00, 0x07, 0x87, 0xa7, 0x4c, 0x52, 0xe5, 0xda, 0xbf, 0xe5, 0x7a, 0x66, 0xf2, 0xf1, 0xe3, 0x8b, 0xde,
0x68, 0x05, 0x77, 0xff, 0xe4, 0xbf, 0x00, 0x00, 0x00, 0xff, 0xff, 0x4e, 0xbf, 0xfa, 0x94, 0x48,
0x0b, 0x00, 0x00,
} }
nodemanager/nodemanager/v1/request_response.proto
View file @ 76bd2751
...@@ -89,6 +89,10 @@ message SubmitTaskResult { ...@@ -89,6 +89,10 @@ message SubmitTaskResult {
bool is_successed = 5; // 任务是否成功 bool is_successed = 5; // 任务是否成功
} }
message SubmitResourceMap {
bytes resource_map = 1; // a bitmap of all task id.
}
message ProofTaskResult { message ProofTaskResult {
string task_uuid = 1; string task_uuid = 1;
uint64 workload = 2; uint64 workload = 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