Skip to content

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

update proto

parent 73d4928d
Hide whitespace changes
Inline Side-by-side
Showing with 334 additions and 386 deletions
baseapi/base/v1/odysseus.proto
View file @ a934bfb6
...@@ -23,7 +23,7 @@ enum BillingMethod { ...@@ -23,7 +23,7 @@ enum BillingMethod {
message TaskContent { message TaskContent {
string task_id = 1; string task_id = 1;
string task_type = 2; TaskType task_type = 2;
string task_cmd =3; string task_cmd =3;
bytes task_param = 4; bytes task_param = 4;
uint64 task_timestamp = 5; uint64 task_timestamp = 5;
......
gen/proto/go/base/v1/odysseus.pb.go
View file @ a934bfb6
...@@ -79,14 +79,17 @@ func (BillingMethod) EnumDescriptor() ([]byte, []int) { ...@@ -79,14 +79,17 @@ func (BillingMethod) EnumDescriptor() ([]byte, []int) {
} }
type TaskContent struct { type TaskContent struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
TaskType TaskType `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=base.v1.TaskType" json:"task_type,omitempty"` TaskType TaskType `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=base.v1.TaskType" json:"task_type,omitempty"`
TaskParam []byte `protobuf:"bytes,3,opt,name=task_param,json=taskParam,proto3" json:"task_param,omitempty"` TaskCmd string `protobuf:"bytes,3,opt,name=task_cmd,json=taskCmd,proto3" json:"task_cmd,omitempty"`
MaxExecuteDuration uint64 `protobuf:"varint,4,opt,name=max_execute_duration,json=maxExecuteDuration,proto3" json:"max_execute_duration,omitempty"` TaskParam []byte `protobuf:"bytes,4,opt,name=task_param,json=taskParam,proto3" json:"task_param,omitempty"`
Model *ModelContent `protobuf:"bytes,5,opt,name=model,proto3" json:"model,omitempty"` TaskTimestamp uint64 `protobuf:"varint,5,opt,name=task_timestamp,json=taskTimestamp,proto3" json:"task_timestamp,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` TaskCallback string `protobuf:"bytes,6,opt,name=task_callback,json=taskCallback,proto3" json:"task_callback,omitempty"`
XXX_unrecognized []byte `json:"-"` TaskUid string `protobuf:"bytes,7,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"`
XXX_sizecache int32 `json:"-"` TaskFee string `protobuf:"bytes,8,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *TaskContent) Reset() { *m = TaskContent{} } func (m *TaskContent) Reset() { *m = TaskContent{} }
...@@ -127,6 +130,13 @@ func (m *TaskContent) GetTaskType() TaskType { ...@@ -127,6 +130,13 @@ func (m *TaskContent) GetTaskType() TaskType {
return TaskType_SystemTask return TaskType_SystemTask
} }
func (m *TaskContent) GetTaskCmd() string {
if m != nil {
return m.TaskCmd
}
return ""
}
func (m *TaskContent) GetTaskParam() []byte { func (m *TaskContent) GetTaskParam() []byte {
if m != nil { if m != nil {
return m.TaskParam return m.TaskParam
...@@ -134,149 +144,144 @@ func (m *TaskContent) GetTaskParam() []byte { ...@@ -134,149 +144,144 @@ func (m *TaskContent) GetTaskParam() []byte {
return nil return nil
} }
func (m *TaskContent) GetMaxExecuteDuration() uint64 { func (m *TaskContent) GetTaskTimestamp() uint64 {
if m != nil { if m != nil {
return m.MaxExecuteDuration return m.TaskTimestamp
} }
return 0 return 0
} }
func (m *TaskContent) GetModel() *ModelContent { func (m *TaskContent) GetTaskCallback() string {
if m != nil { if m != nil {
return m.Model return m.TaskCallback
} }
return nil return ""
}
func (m *TaskContent) GetTaskUid() string {
if m != nil {
return m.TaskUid
}
return ""
}
func (m *TaskContent) GetTaskFee() string {
if m != nil {
return m.TaskFee
}
return ""
} }
func (*TaskContent) XXX_MessageName() string { func (*TaskContent) XXX_MessageName() string {
return "base.v1.TaskContent" return "base.v1.TaskContent"
} }
type ModelContent struct { type TaskResponse struct {
ModelName string `protobuf:"bytes,1,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"` TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
ModelType string `protobuf:"bytes,2,opt,name=model_type,json=modelType,proto3" json:"model_type,omitempty"` TaskResult []byte `protobuf:"bytes,2,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
ModelInstance string `protobuf:"bytes,3,opt,name=model_instance,json=modelInstance,proto3" json:"model_instance,omitempty"` TaskUid string `protobuf:"bytes,3,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"`
RequirePower string `protobuf:"bytes,4,opt,name=require_power,json=requirePower,proto3" json:"require_power,omitempty"` TaskFee string `protobuf:"bytes,4,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"`
Billing BillingMethod `protobuf:"varint,5,opt,name=billing,proto3,enum=base.v1.BillingMethod" json:"billing,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
Cost uint64 `protobuf:"varint,6,opt,name=cost,proto3" json:"cost,omitempty"` XXX_unrecognized []byte `json:"-"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_sizecache int32 `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
} }
func (m *ModelContent) Reset() { *m = ModelContent{} } func (m *TaskResponse) Reset() { *m = TaskResponse{} }
func (m *ModelContent) String() string { return proto.CompactTextString(m) } func (m *TaskResponse) String() string { return proto.CompactTextString(m) }
func (*ModelContent) ProtoMessage() {} func (*TaskResponse) ProtoMessage() {}
func (*ModelContent) Descriptor() ([]byte, []int) { func (*TaskResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_91b466c680c1fa25, []int{1} return fileDescriptor_91b466c680c1fa25, []int{1}
} }
func (m *ModelContent) XXX_Unmarshal(b []byte) error { func (m *TaskResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ModelContent.Unmarshal(m, b) return xxx_messageInfo_TaskResponse.Unmarshal(m, b)
} }
func (m *ModelContent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) { func (m *TaskResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ModelContent.Marshal(b, m, deterministic) return xxx_messageInfo_TaskResponse.Marshal(b, m, deterministic)
} }
func (m *ModelContent) XXX_Merge(src proto.Message) { func (m *TaskResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ModelContent.Merge(m, src) xxx_messageInfo_TaskResponse.Merge(m, src)
} }
func (m *ModelContent) XXX_Size() int { func (m *TaskResponse) XXX_Size() int {
return xxx_messageInfo_ModelContent.Size(m) return xxx_messageInfo_TaskResponse.Size(m)
} }
func (m *ModelContent) XXX_DiscardUnknown() { func (m *TaskResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ModelContent.DiscardUnknown(m) xxx_messageInfo_TaskResponse.DiscardUnknown(m)
} }
var xxx_messageInfo_ModelContent proto.InternalMessageInfo var xxx_messageInfo_TaskResponse proto.InternalMessageInfo
func (m *ModelContent) GetModelName() string { func (m *TaskResponse) GetTaskId() string {
if m != nil { if m != nil {
return m.ModelName return m.TaskId
} }
return "" return ""
} }
func (m *ModelContent) GetModelType() string { func (m *TaskResponse) GetTaskResult() []byte {
if m != nil { if m != nil {
return m.ModelType return m.TaskResult
} }
return "" return nil
} }
func (m *ModelContent) GetModelInstance() string { func (m *TaskResponse) GetTaskUid() string {
if m != nil { if m != nil {
return m.ModelInstance return m.TaskUid
} }
return "" return ""
} }
func (m *ModelContent) GetRequirePower() string { func (m *TaskResponse) GetTaskFee() string {
if m != nil { if m != nil {
return m.RequirePower return m.TaskFee
} }
return "" return ""
} }
func (m *ModelContent) GetBilling() BillingMethod { func (*TaskResponse) XXX_MessageName() string {
if m != nil { return "base.v1.TaskResponse"
return m.Billing
}
return BillingMethod_BillingFree
}
func (m *ModelContent) GetCost() uint64 {
if m != nil {
return m.Cost
}
return 0
}
func (*ModelContent) XXX_MessageName() string {
return "base.v1.ModelContent"
} }
func init() { func init() {
proto.RegisterEnum("base.v1.TaskType", TaskType_name, TaskType_value) proto.RegisterEnum("base.v1.TaskType", TaskType_name, TaskType_value)
proto.RegisterEnum("base.v1.BillingMethod", BillingMethod_name, BillingMethod_value) proto.RegisterEnum("base.v1.BillingMethod", BillingMethod_name, BillingMethod_value)
proto.RegisterType((*TaskContent)(nil), "base.v1.TaskContent") proto.RegisterType((*TaskContent)(nil), "base.v1.TaskContent")
proto.RegisterType((*ModelContent)(nil), "base.v1.ModelContent") proto.RegisterType((*TaskResponse)(nil), "base.v1.TaskResponse")
} }
func init() { proto.RegisterFile("base/v1/odysseus.proto", fileDescriptor_91b466c680c1fa25) } func init() { proto.RegisterFile("base/v1/odysseus.proto", fileDescriptor_91b466c680c1fa25) }
var fileDescriptor_91b466c680c1fa25 = []byte{ var fileDescriptor_91b466c680c1fa25 = []byte{
// 545 bytes of a gzipped FileDescriptorProto // 509 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x54, 0x92, 0xcd, 0x6e, 0xd3, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x92, 0xdf, 0x6a, 0xd4, 0x40,
0x14, 0x85, 0x3b, 0xee, 0x4f, 0x9a, 0x49, 0x93, 0x26, 0x03, 0x2d, 0x56, 0x25, 0x20, 0x2a, 0x42, 0x14, 0xc6, 0x3b, 0xd9, 0x75, 0x77, 0x3b, 0xfb, 0xa7, 0xbb, 0x23, 0x6a, 0x2c, 0x68, 0x97, 0x8a,
0x8a, 0x8a, 0xb0, 0xeb, 0xb0, 0x6b, 0x57, 0x38, 0xfc, 0xa8, 0x48, 0x81, 0xc8, 0x44, 0x51, 0x85, 0xb0, 0x14, 0x4c, 0x88, 0xde, 0xb5, 0x57, 0x66, 0xa5, 0xa2, 0x50, 0x5c, 0x62, 0x5d, 0x8a, 0x14,
0x2a, 0x45, 0x13, 0xfb, 0xe2, 0x5a, 0xcd, 0x78, 0x8c, 0x67, 0x1c, 0x92, 0xb7, 0x41, 0x2c, 0x79, 0xca, 0x24, 0x39, 0x4d, 0xc3, 0x26, 0x99, 0x90, 0x99, 0x59, 0xc8, 0x8d, 0x0f, 0xe1, 0x13, 0x88,
0x12, 0xc4, 0x9a, 0x35, 0x0b, 0xd8, 0xf1, 0x14, 0x68, 0xc6, 0x13, 0x03, 0x2b, 0x5f, 0x7f, 0xe7, 0x97, 0x3e, 0x89, 0xf8, 0x18, 0x7a, 0xe7, 0x53, 0x94, 0x99, 0x64, 0x53, 0x7a, 0xb1, 0x57, 0x39,
0xf8, 0xce, 0x3d, 0xe3, 0x8b, 0x0f, 0x67, 0x54, 0x80, 0xbb, 0xf0, 0x5c, 0x1e, 0xad, 0x84, 0x80, 0xf9, 0x9d, 0x93, 0xef, 0x9b, 0x39, 0xf9, 0xf0, 0x63, 0x9f, 0x72, 0xb0, 0xd7, 0x8e, 0xcd, 0xc2,
0x42, 0x38, 0x59, 0xce, 0x25, 0x27, 0x35, 0xc5, 0x9d, 0x85, 0x77, 0x74, 0x3f, 0xe6, 0x3c, 0x9e, 0x92, 0x73, 0x90, 0xdc, 0xca, 0x0b, 0x26, 0x18, 0xe9, 0x2a, 0x6e, 0xad, 0x9d, 0xfd, 0x83, 0x88,
0x83, 0xab, 0xf1, 0xac, 0x78, 0xef, 0xca, 0x84, 0x81, 0x90, 0x94, 0x65, 0xa5, 0xf3, 0xa8, 0xea, 0xb1, 0x28, 0x01, 0x5b, 0x63, 0x5f, 0x5e, 0xdb, 0x22, 0x4e, 0x81, 0x0b, 0x9a, 0xe6, 0xd5, 0xe4,
0x90, 0x83, 0xe0, 0x45, 0x1e, 0x82, 0xe1, 0xfb, 0x9a, 0xc7, 0x3c, 0xe6, 0x25, 0x38, 0xfe, 0x8e, 0x7e, 0xa3, 0x50, 0x00, 0x67, 0xb2, 0x08, 0xa0, 0xe6, 0x7b, 0x9a, 0x47, 0x2c, 0x62, 0x15, 0x38,
0x70, 0x63, 0x4c, 0xc5, 0xcd, 0x80, 0xa7, 0x12, 0x52, 0x49, 0xee, 0xe0, 0x9a, 0xa4, 0xe2, 0x66, 0xfc, 0x6e, 0xe0, 0xfe, 0x39, 0xe5, 0xab, 0x39, 0xcb, 0x04, 0x64, 0x82, 0x3c, 0xc1, 0x5d, 0x41,
0x9a, 0x44, 0x36, 0xea, 0xa2, 0x5e, 0x3d, 0xd8, 0x51, 0xaf, 0x17, 0x11, 0x71, 0x70, 0x5d, 0x0b, 0xf9, 0xea, 0x2a, 0x0e, 0x4d, 0x34, 0x45, 0xb3, 0x5d, 0xaf, 0xa3, 0x5e, 0x3f, 0x84, 0xc4, 0xc2,
0x72, 0x95, 0x81, 0x6d, 0x75, 0x51, 0xaf, 0xd5, 0xef, 0x38, 0x66, 0x1e, 0x47, 0x75, 0x18, 0xaf, 0xbb, 0xba, 0x21, 0xca, 0x1c, 0x4c, 0x63, 0x8a, 0x66, 0xa3, 0xd7, 0x13, 0xab, 0x3e, 0x8f, 0xa5,
0x32, 0x08, 0x76, 0xa5, 0xa9, 0xc8, 0x5d, 0x8c, 0xb5, 0x3f, 0xa3, 0x39, 0x65, 0xf6, 0x66, 0x17, 0x14, 0xce, 0xcb, 0x1c, 0xbc, 0x9e, 0xa8, 0x2b, 0xf2, 0x14, 0xeb, 0xfa, 0x2a, 0x48, 0x43, 0xb3,
0xf5, 0xf6, 0x02, 0xdd, 0x61, 0xa4, 0x00, 0x39, 0xc5, 0xb7, 0x19, 0x5d, 0x4e, 0x61, 0x09, 0x61, 0xa5, 0x95, 0xb4, 0xf0, 0x3c, 0x0d, 0xc9, 0x33, 0x8c, 0x75, 0x2b, 0xa7, 0x05, 0x4d, 0xcd, 0xf6,
0x21, 0x61, 0x1a, 0x15, 0x39, 0x95, 0x09, 0x4f, 0xed, 0xad, 0x2e, 0xea, 0x6d, 0x05, 0x84, 0xd1, 0x14, 0xcd, 0x06, 0x9e, 0x16, 0x5f, 0x28, 0x40, 0x5e, 0xe2, 0x51, 0xe5, 0xb4, 0xb9, 0x93, 0xf9,
0xe5, 0xf3, 0x52, 0x7a, 0x66, 0x14, 0xf2, 0x08, 0x6f, 0x33, 0x1e, 0xc1, 0xdc, 0xde, 0xee, 0xa2, 0x60, 0x8a, 0x66, 0x6d, 0x6f, 0xa8, 0xb5, 0x37, 0x90, 0xbc, 0xc0, 0xc3, 0xca, 0x80, 0x26, 0x89,
0x5e, 0xa3, 0x7f, 0x50, 0x1d, 0x3e, 0x54, 0xd4, 0xcc, 0x1f, 0x94, 0x9e, 0xe3, 0x1f, 0x08, 0xef, 0x4f, 0x83, 0x95, 0xd9, 0xd1, 0x2e, 0x03, 0xed, 0x52, 0xb3, 0xe6, 0x14, 0x32, 0x0e, 0xcd, 0xee,
0xfd, 0xcb, 0xd5, 0x38, 0x5a, 0x99, 0xa6, 0x94, 0x81, 0x89, 0x56, 0xd7, 0xe4, 0x35, 0x65, 0xf0, 0xdd, 0x29, 0xbe, 0xc4, 0x61, 0xd3, 0xba, 0x06, 0x30, 0x7b, 0x77, 0xad, 0x53, 0x80, 0xc3, 0x6f,
0x57, 0xae, 0xe2, 0xad, 0x65, 0x1d, 0xe6, 0x21, 0x6e, 0x95, 0x72, 0x92, 0x0a, 0x49, 0xd3, 0x10, 0x78, 0xa0, 0x6e, 0xe4, 0x01, 0xcf, 0x59, 0xc6, 0x61, 0xfb, 0x52, 0x0e, 0x70, 0x5f, 0x37, 0x0a,
0x74, 0xa0, 0x7a, 0xd0, 0xd4, 0xf4, 0xc2, 0x40, 0xf2, 0x00, 0x37, 0x73, 0xf8, 0x50, 0x24, 0x39, 0xe0, 0x32, 0x11, 0x7a, 0x2d, 0x03, 0x4f, 0x5f, 0xce, 0xd3, 0xe4, 0x9e, 0x7f, 0x6b, 0xbb, 0x7f,
0x4c, 0x33, 0xfe, 0x11, 0x72, 0x9d, 0xa6, 0x1e, 0xec, 0x19, 0x38, 0x52, 0x8c, 0x9c, 0xe2, 0xda, 0xfb, 0x9e, 0xff, 0xd1, 0x09, 0xee, 0x6d, 0x36, 0x4a, 0x46, 0x18, 0x7f, 0x2e, 0xb9, 0x80, 0x54,
0x2c, 0x99, 0xcf, 0x93, 0x34, 0xd6, 0x49, 0x5a, 0xfd, 0xc3, 0x2a, 0x89, 0x5f, 0xf2, 0x21, 0xc8, 0x91, 0xf1, 0x0e, 0xd9, 0xc3, 0xfd, 0x39, 0x4b, 0x73, 0x29, 0x40, 0x03, 0xa4, 0x06, 0xe6, 0x92,
0x6b, 0x1e, 0x05, 0x6b, 0x1b, 0x21, 0x78, 0x2b, 0xe4, 0x42, 0xda, 0x3b, 0xfa, 0x6e, 0x74, 0x7d, 0x0b, 0x56, 0x0d, 0x18, 0x47, 0x1f, 0xf1, 0xd0, 0x8d, 0x93, 0x24, 0xce, 0xa2, 0x33, 0x10, 0x37,
0x72, 0x8e, 0x77, 0xd7, 0x97, 0x4e, 0x5a, 0x18, 0xbf, 0x5d, 0x09, 0x09, 0x4c, 0x91, 0xf6, 0x06, 0x2c, 0x54, 0x5f, 0xd4, 0xe0, 0xb4, 0x00, 0x18, 0xef, 0x90, 0x49, 0x33, 0xe1, 0x96, 0x6a, 0x9f,
0xd9, 0xc7, 0x8d, 0x01, 0x67, 0x59, 0x21, 0x41, 0x03, 0xa4, 0x0c, 0x83, 0x42, 0x48, 0x5e, 0x1a, 0x63, 0x44, 0x1e, 0xe1, 0x49, 0x83, 0xde, 0xc9, 0x82, 0x8a, 0x98, 0x65, 0x63, 0xc3, 0xfd, 0x81,
0xac, 0x93, 0x57, 0xb8, 0xf9, 0xdf, 0x51, 0xea, 0x0b, 0x03, 0x5e, 0xe4, 0x00, 0xed, 0x0d, 0xd2, 0x7e, 0xff, 0x7b, 0x8e, 0x70, 0x3f, 0x60, 0xe9, 0xe6, 0x5f, 0xbb, 0xc3, 0x4f, 0x75, 0x28, 0x17,
0xa9, 0x1c, 0xfe, 0x6a, 0x9c, 0x30, 0x68, 0x23, 0x72, 0x80, 0x3b, 0x15, 0x5a, 0xff, 0x94, 0xb6, 0x2a, 0x40, 0x0b, 0xf4, 0xf5, 0x6d, 0x14, 0x8b, 0x1b, 0xe9, 0x5b, 0x01, 0x4b, 0x9b, 0xc0, 0x36,
0xe5, 0x7f, 0x42, 0x5f, 0x7f, 0xdd, 0x43, 0xb8, 0x11, 0x72, 0xb6, 0xce, 0xe1, 0x37, 0xdf, 0x98, 0xc5, 0x2b, 0x1d, 0xb3, 0x80, 0x25, 0x76, 0x04, 0x59, 0x95, 0x57, 0x3b, 0x62, 0x76, 0x1d, 0xcf,
0xbd, 0x1d, 0xa9, 0x1d, 0x1b, 0xa1, 0x77, 0x4f, 0xe3, 0x44, 0x5e, 0x17, 0x33, 0x27, 0xe4, 0xac, 0x13, 0xf5, 0x5c, 0x3b, 0x3f, 0x8d, 0x96, 0x7b, 0x71, 0xf1, 0xcb, 0xe8, 0xba, 0xca, 0x63, 0xe9,
0xda, 0xe9, 0xaa, 0x78, 0xac, 0x37, 0x31, 0xe4, 0x73, 0x37, 0x86, 0xb4, 0x5c, 0x69, 0x37, 0xe6, 0xfc, 0xa9, 0xaa, 0xcb, 0xa5, 0xf3, 0xd7, 0x78, 0x58, 0x57, 0x97, 0xef, 0x17, 0xee, 0x19, 0x08,
0xae, 0xd9, 0xe0, 0x73, 0xf5, 0x5c, 0x78, 0x9f, 0xad, 0x4d, 0xff, 0xf2, 0xf2, 0x8b, 0x55, 0xf3, 0x1a, 0x52, 0x41, 0xff, 0x1b, 0x3d, 0x45, 0x8f, 0x8f, 0x97, 0x8e, 0xdf, 0xd1, 0x9a, 0x6f, 0x6e,
0xd5, 0x19, 0x13, 0xef, 0x5b, 0x59, 0x5d, 0x4d, 0xbc, 0x9f, 0xd6, 0x2d, 0x53, 0x5d, 0xbd, 0x1c, 0x03, 0x00, 0x00, 0xff, 0xff, 0xc6, 0x9b, 0x95, 0x41, 0x34, 0x03, 0x00, 0x00,
0xf9, 0x43, 0x90, 0x34, 0xa2, 0x92, 0xfe, 0xb6, 0x76, 0x15, 0x3d, 0x3b, 0x9b, 0x78, 0xb3, 0x1d,
0xdd, 0xf3, 0xc9, 0x9f, 0x00, 0x00, 0x00, 0xff, 0xff, 0x68, 0xd0, 0x53, 0x45, 0x57, 0x03, 0x00,
0x00,
} }
gen/proto/go/nodemanager/v1/request_response.pb.go
View file @ a934bfb6
...@@ -22,34 +22,6 @@ var _ = math.Inf ...@@ -22,34 +22,6 @@ var _ = math.Inf
// proto package needs to be updated. // proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type TaskType int32
const (
TaskType_SystemTask TaskType = 0
TaskType_UserTask TaskType = 1
TaskType_CustomTask TaskType = 2
)
var TaskType_name = map[int32]string{
0: "SystemTask",
1: "UserTask",
2: "CustomTask",
}
var TaskType_value = map[string]int32{
"SystemTask": 0,
"UserTask": 1,
"CustomTask": 2,
}
func (x TaskType) String() string {
return proto.EnumName(TaskType_name, int32(x))
}
func (TaskType) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_810ae261dc8e2975, []int{0}
}
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
...@@ -686,14 +658,14 @@ func (m *StatusResponse) GetDeviceStatus() []byte { ...@@ -686,14 +658,14 @@ func (m *StatusResponse) GetDeviceStatus() []byte {
} }
type PushTaskMessage struct { type PushTaskMessage struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
TaskType TaskType `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=nodemanager.v1.TaskType" json:"task_type,omitempty"` TaskType v1.TaskType `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=base.v1.TaskType" json:"task_type,omitempty"`
WorkLoad uint64 `protobuf:"varint,3,opt,name=work_load,json=workLoad,proto3" json:"work_load,omitempty"` Workload uint64 `protobuf:"varint,3,opt,name=workload,proto3" json:"workload,omitempty"`
TaskCmd string `protobuf:"bytes,4,opt,name=task_cmd,json=taskCmd,proto3" json:"task_cmd,omitempty"` TaskCmd string `protobuf:"bytes,4,opt,name=task_cmd,json=taskCmd,proto3" json:"task_cmd,omitempty"`
TaskParam []byte `protobuf:"bytes,5,opt,name=task_param,json=taskParam,proto3" json:"task_param,omitempty"` TaskParam []byte `protobuf:"bytes,5,opt,name=task_param,json=taskParam,proto3" json:"task_param,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
} }
func (m *PushTaskMessage) Reset() { *m = PushTaskMessage{} } func (m *PushTaskMessage) Reset() { *m = PushTaskMessage{} }
...@@ -727,16 +699,16 @@ func (m *PushTaskMessage) GetTaskId() string { ...@@ -727,16 +699,16 @@ func (m *PushTaskMessage) GetTaskId() string {
return "" return ""
} }
func (m *PushTaskMessage) GetTaskType() TaskType { func (m *PushTaskMessage) GetTaskType() v1.TaskType {
if m != nil { if m != nil {
return m.TaskType return m.TaskType
} }
return TaskType_SystemTask return v1.TaskType_SystemTask
} }
func (m *PushTaskMessage) GetWorkLoad() uint64 { func (m *PushTaskMessage) GetWorkload() uint64 {
if m != nil { if m != nil {
return m.WorkLoad return m.Workload
} }
return 0 return 0
} }
...@@ -757,8 +729,8 @@ func (m *PushTaskMessage) GetTaskParam() []byte { ...@@ -757,8 +729,8 @@ func (m *PushTaskMessage) GetTaskParam() []byte {
type SubmitTaskResult struct { type SubmitTaskResult struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
TaskProof []byte `protobuf:"bytes,2,opt,name=task_proof,json=taskProof,proto3" json:"task_proof,omitempty"` ContainerSignature []byte `protobuf:"bytes,2,opt,name=container_signature,json=containerSignature,proto3" json:"container_signature,omitempty"`
WorkerSignature []byte `protobuf:"bytes,3,opt,name=worker_signature,json=workerSignature,proto3" json:"worker_signature,omitempty"` MinerSignature []byte `protobuf:"bytes,3,opt,name=miner_signature,json=minerSignature,proto3" json:"miner_signature,omitempty"`
TaskResult []byte `protobuf:"bytes,4,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"` TaskResult []byte `protobuf:"bytes,4,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
...@@ -796,16 +768,16 @@ func (m *SubmitTaskResult) GetTaskId() string { ...@@ -796,16 +768,16 @@ func (m *SubmitTaskResult) GetTaskId() string {
return "" return ""
} }
func (m *SubmitTaskResult) GetTaskProof() []byte { func (m *SubmitTaskResult) GetContainerSignature() []byte {
if m != nil { if m != nil {
return m.TaskProof return m.ContainerSignature
} }
return nil return nil
} }
func (m *SubmitTaskResult) GetWorkerSignature() []byte { func (m *SubmitTaskResult) GetMinerSignature() []byte {
if m != nil { if m != nil {
return m.WorkerSignature return m.MinerSignature
} }
return nil return nil
} }
...@@ -864,10 +836,8 @@ func (m *ProofTaskResult) GetManagerSignature() []byte { ...@@ -864,10 +836,8 @@ func (m *ProofTaskResult) GetManagerSignature() []byte {
} }
type DispatchTaskRequest struct { type DispatchTaskRequest struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskData *v1.TaskContent `protobuf:"bytes,1,opt,name=task_data,json=taskData,proto3" json:"task_data,omitempty"`
TaskType TaskType `protobuf:"varint,2,opt,name=task_type,json=taskType,proto3,enum=nodemanager.v1.TaskType" json:"task_type,omitempty"` Miner string `protobuf:"bytes,2,opt,name=miner,proto3" json:"miner,omitempty"`
TaskData *v1.TaskContent `protobuf:"bytes,3,opt,name=task_data,json=taskData,proto3" json:"task_data,omitempty"`
Worker string `protobuf:"bytes,4,opt,name=worker,proto3" json:"worker,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
...@@ -897,20 +867,6 @@ func (m *DispatchTaskRequest) XXX_DiscardUnknown() { ...@@ -897,20 +867,6 @@ func (m *DispatchTaskRequest) XXX_DiscardUnknown() {
var xxx_messageInfo_DispatchTaskRequest proto.InternalMessageInfo var xxx_messageInfo_DispatchTaskRequest proto.InternalMessageInfo
func (m *DispatchTaskRequest) GetTaskId() string {
if m != nil {
return m.TaskId
}
return ""
}
func (m *DispatchTaskRequest) GetTaskType() TaskType {
if m != nil {
return m.TaskType
}
return TaskType_SystemTask
}
func (m *DispatchTaskRequest) GetTaskData() *v1.TaskContent { func (m *DispatchTaskRequest) GetTaskData() *v1.TaskContent {
if m != nil { if m != nil {
return m.TaskData return m.TaskData
...@@ -918,16 +874,16 @@ func (m *DispatchTaskRequest) GetTaskData() *v1.TaskContent { ...@@ -918,16 +874,16 @@ func (m *DispatchTaskRequest) GetTaskData() *v1.TaskContent {
return nil return nil
} }
func (m *DispatchTaskRequest) GetWorker() string { func (m *DispatchTaskRequest) GetMiner() string {
if m != nil { if m != nil {
return m.Worker return m.Miner
} }
return "" return ""
} }
type DispatchTaskResponse struct { type DispatchTaskResponse struct {
TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
WorkerId string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"` Miner string `protobuf:"bytes,2,opt,name=miner,proto3" json:"miner,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
...@@ -964,9 +920,9 @@ func (m *DispatchTaskResponse) GetTaskId() string { ...@@ -964,9 +920,9 @@ func (m *DispatchTaskResponse) GetTaskId() string {
return "" return ""
} }
func (m *DispatchTaskResponse) GetWorkerId() string { func (m *DispatchTaskResponse) GetMiner() string {
if m != nil { if m != nil {
return m.WorkerId return m.Miner
} }
return "" return ""
} }
...@@ -1040,7 +996,6 @@ func (m *ManagerListResponse) GetManagers() []NodeManagerInfo { ...@@ -1040,7 +996,6 @@ func (m *ManagerListResponse) GetManagers() []NodeManagerInfo {
} }
func init() { func init() {
proto.RegisterEnum("nodemanager.v1.TaskType", TaskType_name, TaskType_value)
proto.RegisterType((*WorkerMessage)(nil), "nodemanager.v1.WorkerMessage") proto.RegisterType((*WorkerMessage)(nil), "nodemanager.v1.WorkerMessage")
proto.RegisterType((*ManagerMessage)(nil), "nodemanager.v1.ManagerMessage") proto.RegisterType((*ManagerMessage)(nil), "nodemanager.v1.ManagerMessage")
proto.RegisterType((*GoodbyeMessage)(nil), "nodemanager.v1.GoodbyeMessage") proto.RegisterType((*GoodbyeMessage)(nil), "nodemanager.v1.GoodbyeMessage")
...@@ -1067,71 +1022,68 @@ func init() { ...@@ -1067,71 +1022,68 @@ func init() {
} }
var fileDescriptor_810ae261dc8e2975 = []byte{ var fileDescriptor_810ae261dc8e2975 = []byte{
// 1044 bytes of a gzipped FileDescriptorProto // 993 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0x4f, 0x6f, 0xe3, 0xc4, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xa4, 0x56, 0xcf, 0x6f, 0xe3, 0x44,
0x1b, 0xce, 0xbf, 0xa6, 0xc9, 0xdb, 0xd4, 0x49, 0xa6, 0xd5, 0xfe, 0xf2, 0xeb, 0x52, 0xda, 0xf5, 0x14, 0x6e, 0x7e, 0xf4, 0x47, 0x5e, 0x5a, 0xbb, 0x99, 0x44, 0x4b, 0x08, 0x94, 0x76, 0xbd, 0x42,
0x0a, 0xa9, 0x80, 0x48, 0x70, 0x61, 0xa5, 0xd5, 0x72, 0x22, 0x2d, 0x34, 0x5d, 0xb5, 0xdd, 0xe0, 0x54, 0x42, 0xc4, 0xb8, 0x80, 0x84, 0x96, 0x13, 0xd9, 0x2e, 0x4d, 0x57, 0xb4, 0x1b, 0xbc, 0x4b,
0xee, 0x76, 0x2b, 0xb4, 0x52, 0x34, 0x89, 0xa7, 0x4e, 0xd4, 0xda, 0x63, 0x3c, 0xe3, 0xac, 0xf2, 0xb7, 0x42, 0x2b, 0xa2, 0x49, 0x3c, 0x75, 0xac, 0xd6, 0x1e, 0xe3, 0x19, 0x07, 0xf5, 0xdf, 0xe1,
0x45, 0xf8, 0x00, 0x1c, 0x39, 0x21, 0x4e, 0x7c, 0x04, 0xc4, 0x19, 0x71, 0xe4, 0xc0, 0x91, 0x4f, 0xc0, 0x81, 0x13, 0xe2, 0xaf, 0x40, 0x9c, 0x11, 0x47, 0x0e, 0x1c, 0xf9, 0x2b, 0x90, 0x67, 0xc6,
0x81, 0xe6, 0x8f, 0x53, 0xdb, 0x69, 0xba, 0x07, 0xb8, 0x79, 0x9e, 0x79, 0xe7, 0x99, 0x67, 0xe6, 0xae, 0xed, 0x24, 0xdd, 0x03, 0xb7, 0xcc, 0x9b, 0x6f, 0xbe, 0xf7, 0x66, 0xbe, 0xef, 0xbd, 0x18,
0x79, 0xdf, 0xd7, 0x03, 0x1f, 0xf8, 0xd4, 0x21, 0x1e, 0xf6, 0xb1, 0x4b, 0xc2, 0xce, 0xd4, 0xea, 0xde, 0x0f, 0xa8, 0x43, 0x7c, 0x1c, 0x60, 0x97, 0x44, 0xe6, 0xdc, 0x32, 0x23, 0xf2, 0x43, 0x4c,
0x84, 0xe4, 0xbb, 0x88, 0x30, 0x3e, 0x08, 0x09, 0x0b, 0xa8, 0xcf, 0x48, 0x3b, 0x08, 0x29, 0xa7, 0x18, 0x1f, 0x47, 0x84, 0x85, 0x34, 0x60, 0xa4, 0x1f, 0x46, 0x94, 0x53, 0xa4, 0xe5, 0x60, 0xfd,
0xc8, 0x48, 0x84, 0xb5, 0xa7, 0xd6, 0x56, 0x7d, 0x88, 0x19, 0xe9, 0xb8, 0xd4, 0xa5, 0x2a, 0x60, 0xb9, 0xd5, 0xd3, 0x27, 0x98, 0x11, 0xd3, 0xa5, 0x2e, 0x95, 0x80, 0xde, 0x03, 0x11, 0x98, 0x5b,
0xeb, 0x81, 0x04, 0xa6, 0x56, 0x87, 0x3a, 0x33, 0xc6, 0x48, 0xc4, 0x34, 0xbe, 0xbd, 0xc0, 0xcf, 0x26, 0x75, 0x6e, 0x19, 0x23, 0x31, 0x53, 0xf1, 0xbd, 0x05, 0x7e, 0x46, 0xe3, 0x68, 0xaa, 0x78,
0x68, 0x14, 0x8e, 0x34, 0xaf, 0xf9, 0x47, 0x11, 0xd6, 0x5f, 0xd3, 0xf0, 0x9a, 0x84, 0xa7, 0x84, 0x8d, 0xbf, 0x6a, 0xb0, 0xf3, 0x8a, 0x46, 0xd7, 0x24, 0x3a, 0x23, 0x8c, 0x61, 0x97, 0x20, 0x1b,
0x31, 0xec, 0x12, 0x64, 0x03, 0x1a, 0x13, 0x1c, 0xf2, 0x21, 0xc1, 0xb7, 0x2a, 0x5a, 0xf9, 0xdd, 0xd0, 0x8c, 0xe0, 0x88, 0x4f, 0x08, 0xbe, 0xab, 0xa2, 0x5b, 0x39, 0xa8, 0x1c, 0x36, 0x8f, 0x1e,
0xfc, 0xde, 0xda, 0xfe, 0xa3, 0x76, 0x5a, 0x46, 0xbb, 0x17, 0x47, 0xda, 0x3a, 0xb0, 0x97, 0xb3, 0xf6, 0x8b, 0x65, 0xf4, 0x87, 0x29, 0xd2, 0x56, 0xc0, 0xe1, 0x9a, 0xdd, 0x9a, 0x95, 0x83, 0x68,
0x9b, 0xe3, 0x2c, 0x88, 0xfa, 0x80, 0x58, 0x34, 0xf4, 0x26, 0x7c, 0xc0, 0x31, 0xbb, 0x16, 0xac, 0x04, 0x88, 0xc5, 0x13, 0xdf, 0xe3, 0x63, 0x8e, 0xd9, 0x75, 0xc2, 0x1a, 0xdf, 0xf0, 0x6e, 0x55,
0xd1, 0x0d, 0x6f, 0x15, 0x24, 0xe7, 0x6e, 0x96, 0xf3, 0x5c, 0x46, 0xbe, 0xc4, 0xec, 0xda, 0x96, 0x70, 0x1e, 0x94, 0x39, 0x5f, 0x08, 0xe4, 0x4b, 0xcc, 0xae, 0x6d, 0x81, 0x1b, 0xae, 0xd9, 0xbb,
0x71, 0xbd, 0x9c, 0xdd, 0x60, 0x19, 0x0c, 0x3d, 0x85, 0x32, 0xe3, 0x98, 0x47, 0xac, 0x55, 0x94, 0xac, 0x14, 0x43, 0x9f, 0xc3, 0x06, 0xe3, 0x98, 0xc7, 0xac, 0x5b, 0x13, 0x2c, 0xef, 0x2d, 0xb0,
0x2c, 0xef, 0x2f, 0xb0, 0xc8, 0xd9, 0x84, 0x2c, 0x1d, 0x8f, 0xbe, 0x82, 0x35, 0x87, 0x4c, 0x27, 0x88, 0xdd, 0x5c, 0x59, 0x0a, 0x8f, 0x9e, 0x42, 0xd3, 0x21, 0x73, 0x6f, 0x4a, 0xc6, 0x5e, 0x70,
0x23, 0x32, 0x98, 0xf8, 0x57, 0xb4, 0x55, 0x92, 0xcb, 0xcd, 0xec, 0xf2, 0x43, 0x19, 0x72, 0xec, 0x45, 0xbb, 0x75, 0x71, 0xdc, 0x28, 0x1f, 0x3f, 0x16, 0x90, 0xd3, 0xe0, 0x8a, 0xe6, 0x28, 0xc0,
0x5f, 0xd1, 0x04, 0x05, 0x38, 0x73, 0x14, 0xf5, 0xa0, 0xa6, 0x69, 0x22, 0x71, 0x6d, 0xad, 0x15, 0xc9, 0xa2, 0x68, 0x08, 0xdb, 0x8a, 0x26, 0x4e, 0x9e, 0xad, 0xbb, 0x2e, 0x78, 0x1e, 0x2d, 0xe7,
0xc9, 0xf3, 0xf8, 0x6e, 0x9e, 0x57, 0x22, 0x24, 0x41, 0xa4, 0x15, 0x48, 0x18, 0x1d, 0x43, 0xdd, 0xf9, 0x36, 0x81, 0xe4, 0x88, 0x54, 0x05, 0x22, 0x8c, 0x4e, 0x41, 0x77, 0x29, 0x75, 0x26, 0xb7,
0xa5, 0xd4, 0x19, 0xce, 0xc8, 0xc0, 0x53, 0x1e, 0xb4, 0xca, 0x77, 0x9f, 0xe9, 0x48, 0x85, 0x69, 0x64, 0xec, 0x4b, 0x0d, 0xba, 0x1b, 0xcb, 0xef, 0x74, 0x22, 0x61, 0x4a, 0xa9, 0xe1, 0x9a, 0xad,
0xa7, 0x7a, 0x39, 0xdb, 0x70, 0x53, 0x48, 0xb7, 0x0a, 0xab, 0x9a, 0xc2, 0xfc, 0xb9, 0x04, 0xc6, 0xb9, 0x85, 0xc8, 0xa0, 0x01, 0x9b, 0x8a, 0xc2, 0xf8, 0xad, 0x0e, 0xda, 0x99, 0x3c, 0x9a, 0x2a,
0xa9, 0x5a, 0x1a, 0x3b, 0xfb, 0x02, 0x9a, 0x49, 0x67, 0x65, 0x9e, 0x69, 0x63, 0x77, 0xef, 0x31, 0xfb, 0x1c, 0x5a, 0x79, 0x65, 0x85, 0xcf, 0x94, 0xb0, 0x07, 0xf7, 0x08, 0x2b, 0x70, 0x89, 0x08,
0x56, 0xc6, 0x09, 0x13, 0xc6, 0x19, 0x0c, 0x9d, 0x42, 0x33, 0x88, 0xd8, 0x58, 0x99, 0x1a, 0x6b, 0xb3, 0x52, 0x0c, 0x9d, 0x41, 0x2b, 0x8c, 0xd9, 0x4c, 0x8a, 0x9a, 0xd6, 0x2e, 0x55, 0xdd, 0x2f,
0x57, 0xae, 0xee, 0x64, 0x09, 0xfb, 0x11, 0x1b, 0x0b, 0xff, 0x6e, 0xc5, 0xd7, 0x83, 0x34, 0x24, 0x13, 0x8e, 0x62, 0x36, 0x4b, 0xf4, 0xbb, 0x2b, 0x5e, 0x0f, 0x8b, 0x21, 0x41, 0x17, 0x51, 0x7a,
0xe9, 0x42, 0x4a, 0xaf, 0x52, 0x49, 0x52, 0x5c, 0x42, 0x27, 0x02, 0x53, 0x39, 0x52, 0x0f, 0xd2, 0x55, 0x30, 0x49, 0x6d, 0x05, 0x5d, 0x02, 0x2c, 0x78, 0x44, 0x0f, 0x8b, 0x21, 0xf4, 0x15, 0x68,
0x10, 0xfa, 0x1a, 0x0c, 0x65, 0xf9, 0xfc, 0xac, 0xca, 0xeb, 0xed, 0x65, 0xa9, 0x12, 0x1f, 0x74, 0x52, 0xf2, 0xec, 0xae, 0x52, 0xeb, 0xbd, 0x55, 0x56, 0x49, 0x2f, 0xba, 0xc3, 0xf2, 0x01, 0xf4,
0x9d, 0x25, 0x01, 0xf4, 0x1c, 0x0c, 0xed, 0x74, 0xcc, 0xb3, 0x72, 0x77, 0x31, 0x24, 0x73, 0x66, 0x0c, 0x34, 0xa5, 0x74, 0xca, 0xb3, 0xbe, 0xbc, 0x19, 0xf2, 0x9e, 0xc9, 0xb8, 0xe4, 0xd1, 0x94,
0xce, 0xa5, 0x96, 0xc6, 0x5c, 0x47, 0x99, 0xac, 0x29, 0xdf, 0x97, 0x7d, 0x3a, 0x6b, 0x62, 0xaa, 0xeb, 0xa4, 0xe4, 0x9a, 0x8d, 0xfb, 0xdc, 0xa7, 0x5c, 0x93, 0x52, 0xbd, 0xc9, 0x34, 0x9b, 0xff,
0x77, 0x25, 0xcd, 0xea, 0xbf, 0x4f, 0x9a, 0x3d, 0x30, 0xd2, 0xe1, 0xe8, 0x01, 0x94, 0x43, 0x82, 0xdf, 0x34, 0x87, 0xa0, 0x15, 0xe1, 0xe8, 0x01, 0x6c, 0x44, 0x04, 0x33, 0x1a, 0x08, 0xa3, 0x34,
0x19, 0xf5, 0x65, 0xa2, 0x54, 0x6d, 0x3d, 0x32, 0x3f, 0x85, 0x46, 0x36, 0x45, 0xd0, 0x7b, 0x50, 0x6c, 0xb5, 0x32, 0x3e, 0x86, 0xdd, 0xb2, 0x45, 0xd0, 0xbb, 0xd0, 0xe0, 0x9e, 0x4f, 0x18, 0xc7,
0xe5, 0x13, 0x8f, 0x30, 0x8e, 0xbd, 0x40, 0x86, 0x97, 0xec, 0x5b, 0xc0, 0xb4, 0xa0, 0xb9, 0xd0, 0x7e, 0x28, 0xe0, 0x75, 0xfb, 0x2e, 0x60, 0x58, 0xd0, 0x5a, 0x98, 0x16, 0x6f, 0x38, 0xa2, 0xc3,
0x2d, 0xde, 0xb1, 0xa4, 0x0e, 0xeb, 0x29, 0x6f, 0xcc, 0x4d, 0x40, 0x8b, 0x57, 0x63, 0xf6, 0x60, 0x4e, 0x41, 0x1b, 0xa3, 0x03, 0x68, 0xf1, 0x69, 0x8c, 0x21, 0xb4, 0x97, 0xb4, 0x19, 0xb2, 0x60,
0xe3, 0x8e, 0x32, 0x43, 0x16, 0xac, 0xa8, 0x4b, 0xce, 0xef, 0x16, 0xf7, 0xd6, 0xf6, 0x1f, 0xde, 0x5d, 0x3e, 0x72, 0xe5, 0xa0, 0x76, 0xd8, 0x3c, 0x7a, 0xe7, 0xbe, 0x47, 0x96, 0x48, 0xa3, 0x0d,
0x77, 0xc9, 0x2a, 0xd2, 0xdc, 0x80, 0xe6, 0x82, 0x89, 0xe6, 0xf3, 0x78, 0xd3, 0x64, 0x37, 0x40, 0xad, 0x05, 0x11, 0x8d, 0x67, 0x69, 0xd2, 0xfc, 0x34, 0x40, 0x9f, 0xc2, 0xa6, 0xd4, 0x83, 0x29,
0x9f, 0xc3, 0xaa, 0xf2, 0x83, 0x69, 0xfe, 0xad, 0x7b, 0xd2, 0x21, 0x0e, 0x35, 0xbf, 0x81, 0xb5, 0xfe, 0xde, 0x3d, 0x76, 0x48, 0xa1, 0xc6, 0x37, 0xd0, 0xcc, 0xa5, 0x45, 0xfb, 0xd9, 0x2c, 0xe2,
0xc4, 0xb6, 0x68, 0x67, 0xde, 0x8b, 0xf8, 0x2c, 0x20, 0xfa, 0x8a, 0x75, 0x97, 0x79, 0x39, 0x0b, 0xb7, 0x21, 0x51, 0x4f, 0xac, 0xa6, 0xcc, 0xcb, 0xdb, 0x90, 0xa0, 0x87, 0x25, 0xbf, 0x54, 0xc5,
0x08, 0x7a, 0x94, 0xc9, 0x97, 0x82, 0xbc, 0xa2, 0x64, 0x26, 0x98, 0x4f, 0xc0, 0x48, 0xf7, 0x3a, 0x13, 0xe5, 0x9d, 0x60, 0x7c, 0x06, 0x5a, 0x71, 0xd6, 0xa1, 0x47, 0xa0, 0x5c, 0x37, 0x56, 0x23,
0xf4, 0x18, 0x74, 0xd6, 0x0d, 0x74, 0x8b, 0x14, 0xbc, 0x35, 0x5b, 0x33, 0xa9, 0x60, 0xf3, 0x97, 0x32, 0xe1, 0xdd, 0xb6, 0x15, 0x93, 0x04, 0x1b, 0xbf, 0x56, 0x40, 0x2f, 0xf5, 0x24, 0x7a, 0x0b,
0x3c, 0xd4, 0x33, 0x35, 0x89, 0xfe, 0x07, 0xab, 0xb2, 0xf4, 0x26, 0x4e, 0xec, 0xb6, 0x18, 0x1e, 0x36, 0x45, 0xeb, 0x79, 0x4e, 0xaa, 0x76, 0xb2, 0x3c, 0x75, 0x50, 0x1f, 0x1a, 0x62, 0x43, 0x54,
0x3b, 0xe8, 0x09, 0x54, 0xe5, 0x84, 0x54, 0x29, 0x34, 0x18, 0xfb, 0xad, 0xec, 0x71, 0x05, 0x91, 0x99, 0xd4, 0xa0, 0x1d, 0xb5, 0xfa, 0xc9, 0x1f, 0x4e, 0x72, 0xcf, 0x84, 0x21, 0x29, 0xd6, 0xde,
0xd0, 0x6c, 0x57, 0xb8, 0xfe, 0x42, 0x0f, 0xa1, 0xfa, 0x96, 0x86, 0xd7, 0x83, 0x1b, 0x8a, 0x1d, 0xe2, 0xea, 0x17, 0xea, 0xc1, 0xd6, 0x8f, 0x34, 0xba, 0xbe, 0xa1, 0xd8, 0x11, 0x0d, 0x5c, 0xb7,
0x59, 0xc8, 0x25, 0xbb, 0x22, 0x80, 0x13, 0x8a, 0x1d, 0xf4, 0x7f, 0x90, 0x81, 0x83, 0x91, 0xe7, 0xb3, 0x35, 0x7a, 0x1b, 0x04, 0x6e, 0x3c, 0xf5, 0x1d, 0xd1, 0x90, 0x0d, 0x5b, 0x24, 0x7d, 0xe2,
0xc8, 0xc2, 0xac, 0xda, 0x72, 0xf3, 0x03, 0xcf, 0x41, 0xdb, 0x00, 0x72, 0x2a, 0xc0, 0x21, 0xf6, 0x3b, 0x68, 0x0f, 0x40, 0x6c, 0x85, 0x38, 0xc2, 0xbe, 0xe8, 0xb2, 0x6d, 0x5b, 0x24, 0x1e, 0x25,
0x64, 0xb5, 0xd5, 0x6c, 0x29, 0xa0, 0x2f, 0x00, 0xf3, 0xfb, 0x3c, 0x34, 0xb2, 0x3f, 0x89, 0xe5, 0x01, 0xe3, 0xe7, 0x0a, 0xec, 0x96, 0xff, 0x1c, 0x56, 0xd7, 0x6c, 0x42, 0x7b, 0x4a, 0x03, 0x8e,
0xda, 0xe7, 0x64, 0xa2, 0x3d, 0x48, 0xf1, 0x31, 0x99, 0x00, 0xd0, 0x87, 0xd0, 0x78, 0x2b, 0xff, 0xbd, 0x80, 0x44, 0x63, 0xe6, 0xb9, 0x01, 0xe6, 0x71, 0x24, 0xab, 0xdf, 0xb6, 0x51, 0xb6, 0xf5,
0x7f, 0x03, 0x36, 0x71, 0x7d, 0xcc, 0xa3, 0x90, 0x48, 0xa9, 0x35, 0xbb, 0xae, 0xf0, 0xf3, 0x18, 0x22, 0xdd, 0x41, 0x1f, 0x80, 0xee, 0x97, 0xc0, 0x35, 0x01, 0xd6, 0xfc, 0x22, 0x70, 0x1f, 0x9a,
0x16, 0x6e, 0x25, 0x3b, 0x53, 0x49, 0x46, 0x49, 0x72, 0xa5, 0xc1, 0x7c, 0x0d, 0xf5, 0x4c, 0x5f, 0xf9, 0x09, 0x55, 0x17, 0x20, 0x51, 0xb9, 0xac, 0xc9, 0x78, 0x05, 0x7a, 0x69, 0x3e, 0xad, 0x2e,
0x5a, 0x2e, 0xeb, 0x63, 0x68, 0xea, 0xcb, 0x4b, 0x6c, 0xac, 0xd4, 0x35, 0xf4, 0xc4, 0x7c, 0x67, 0xf3, 0x43, 0x68, 0x29, 0xcf, 0x2c, 0x14, 0xb9, 0xab, 0x36, 0xb2, 0xcc, 0xc6, 0xf7, 0xd0, 0x3e,
0xf3, 0xa7, 0x3c, 0x6c, 0x1c, 0x4e, 0x58, 0x80, 0xf9, 0x68, 0xac, 0xc8, 0x55, 0xc5, 0xfd, 0xd7, 0xf6, 0x58, 0x88, 0xf9, 0x74, 0x26, 0xb9, 0x65, 0xe3, 0x59, 0x4a, 0x1e, 0x07, 0x73, 0xac, 0x06,
0x86, 0x59, 0x7a, 0x99, 0x83, 0x39, 0xd6, 0x9d, 0x77, 0xb3, 0x2d, 0x1e, 0x16, 0x71, 0xfc, 0x01, 0x7a, 0xa7, 0x20, 0xcf, 0x13, 0x1a, 0x70, 0x12, 0x70, 0xa9, 0xd0, 0x31, 0xe6, 0x18, 0x75, 0x60,
0xf5, 0x39, 0xf1, 0xb9, 0x5a, 0x72, 0x88, 0x39, 0x16, 0x0d, 0x42, 0xdd, 0x93, 0x36, 0x51, 0x8f, 0x5d, 0xdc, 0x4a, 0xa4, 0x6a, 0xd8, 0x72, 0x61, 0x3c, 0x85, 0x4e, 0x91, 0x5f, 0x39, 0x6a, 0x65,
0xcc, 0x13, 0xd8, 0x4c, 0x2b, 0xd6, 0xc9, 0xb9, 0x54, 0xb2, 0x4e, 0x16, 0x12, 0x8a, 0xa9, 0x82, 0xf5, 0xcb, 0x69, 0x3a, 0x80, 0xd4, 0x5f, 0xcf, 0xd7, 0x1e, 0x4b, 0xc7, 0x83, 0x71, 0x09, 0xed,
0x9c, 0xaa, 0x28, 0xe0, 0xd8, 0x11, 0x85, 0xaf, 0x7f, 0x66, 0x27, 0x13, 0x16, 0x37, 0x1c, 0xf3, 0x42, 0x54, 0x71, 0x7f, 0x09, 0x5b, 0xea, 0x9e, 0x69, 0x27, 0x2d, 0x0c, 0xfb, 0x73, 0xea, 0x10,
0x12, 0x36, 0x52, 0xa8, 0xde, 0xe2, 0x4b, 0xa8, 0xe8, 0x63, 0xc6, 0xb5, 0xb9, 0xf0, 0xfb, 0x38, 0x75, 0x34, 0x69, 0xa7, 0x41, 0xfd, 0xf7, 0xbf, 0xf7, 0xd7, 0xec, 0xec, 0xd8, 0xe0, 0xcf, 0x0a,
0xa3, 0x0e, 0xd1, 0x4b, 0x45, 0x81, 0x76, 0x4b, 0xbf, 0xfe, 0xb9, 0x93, 0xb3, 0xe7, 0xcb, 0x3e, 0xa0, 0x29, 0xf5, 0x4b, 0xc7, 0x06, 0x1d, 0x95, 0x39, 0x4d, 0x35, 0x4a, 0xbe, 0x78, 0x46, 0x95,
0x7a, 0x0a, 0x95, 0xf8, 0x7a, 0x90, 0x01, 0x70, 0x3e, 0x63, 0x9c, 0x78, 0x02, 0x69, 0xe4, 0x50, 0xef, 0x9e, 0xbb, 0x1e, 0x9f, 0xc5, 0x93, 0xfe, 0x94, 0xfa, 0xd9, 0xd7, 0x52, 0xf6, 0xe3, 0x23,
0x0d, 0x2a, 0xaf, 0x18, 0x09, 0xe5, 0x28, 0x2f, 0x66, 0x0f, 0x22, 0xc6, 0xa9, 0x9a, 0x2d, 0x74, 0xf1, 0x5d, 0x34, 0xa5, 0x37, 0xa6, 0x4b, 0x02, 0x53, 0x2c, 0x4c, 0x97, 0x9a, 0xc5, 0xaf, 0xa8,
0x7f, 0xcf, 0x03, 0x1a, 0x51, 0x2f, 0xb3, 0x61, 0x77, 0x53, 0x6b, 0x8e, 0x45, 0xf6, 0xc5, 0xeb, 0x2f, 0x72, 0xcb, 0xb9, 0xf5, 0x53, 0xb5, 0x76, 0x7e, 0x79, 0xf9, 0x4b, 0x55, 0x3b, 0xcf, 0xe5,
0xab, 0x9f, 0xff, 0xf6, 0x85, 0x3b, 0xe1, 0xe3, 0x68, 0xd8, 0x1e, 0x51, 0x6f, 0xfe, 0x72, 0x9b, 0xbf, 0xb0, 0xfe, 0x28, 0x04, 0x5e, 0x5f, 0x58, 0xff, 0x54, 0x7b, 0xc5, 0xc0, 0xeb, 0x93, 0xd1,
0x7f, 0x7c, 0x22, 0xdf, 0x68, 0x23, 0x7a, 0xd3, 0x71, 0x89, 0xdf, 0x91, 0x83, 0x8e, 0x4b, 0x3b, 0xe0, 0x8c, 0x70, 0x9c, 0xe8, 0xf6, 0x6f, 0x55, 0xcf, 0x6d, 0x3e, 0x7e, 0x7c, 0x61, 0x4d, 0x36,
0xe9, 0x17, 0xdd, 0x17, 0x89, 0xe1, 0xd4, 0xfa, 0xa1, 0x50, 0x3c, 0xbb, 0xbc, 0xfc, 0xb1, 0x60, 0x44, 0xf6, 0x4f, 0xfe, 0x0b, 0x00, 0x00, 0xff, 0xff, 0x7f, 0x95, 0xde, 0xda, 0x23, 0x0a, 0x00,
0x9c, 0x25, 0xf6, 0xbf, 0xb0, 0x7e, 0x4b, 0x01, 0x6f, 0x2e, 0xac, 0xbf, 0x0a, 0x5b, 0x69, 0xe0, 0x00,
0xcd, 0x51, 0xbf, 0x7b, 0x4a, 0x38, 0x16, 0xd6, 0xff, 0x5d, 0xa8, 0x27, 0x26, 0x9f, 0x3d, 0xbb,
0xb0, 0x86, 0x65, 0xb9, 0xfb, 0x67, 0xff, 0x04, 0x00, 0x00, 0xff, 0xff, 0x4d, 0x6c, 0xbd, 0x1b,
0xaf, 0x0a, 0x00, 0x00,
} }
gen/proto/go/nodemanager/v1/resource.pb.go
View file @ a934bfb6
...@@ -129,9 +129,9 @@ func (m *DeviceInfo) GetDevicePower() uint64 { ...@@ -129,9 +129,9 @@ func (m *DeviceInfo) GetDevicePower() uint64 {
} }
type WorkerContent struct { type WorkerContent struct {
WorkerPubkey string `protobuf:"bytes,1,opt,name=worker_pubkey,json=workerPubkey,proto3" json:"worker_pubkey,omitempty"` MinerPubkey string `protobuf:"bytes,1,opt,name=miner_pubkey,json=minerPubkey,proto3" json:"miner_pubkey,omitempty"`
Devices []*DeviceInfo `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"` Devices []*DeviceInfo `protobuf:"bytes,2,rep,name=devices,proto3" json:"devices,omitempty"`
DeviceProof []byte `protobuf:"bytes,3,opt,name=device_proof,json=deviceProof,proto3" json:"device_proof,omitempty"` DeviceSignature []byte `protobuf:"bytes,3,opt,name=device_signature,json=deviceSignature,proto3" json:"device_signature,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"` XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"` XXX_sizecache int32 `json:"-"`
...@@ -161,9 +161,9 @@ func (m *WorkerContent) XXX_DiscardUnknown() { ...@@ -161,9 +161,9 @@ func (m *WorkerContent) XXX_DiscardUnknown() {
var xxx_messageInfo_WorkerContent proto.InternalMessageInfo var xxx_messageInfo_WorkerContent proto.InternalMessageInfo
func (m *WorkerContent) GetWorkerPubkey() string { func (m *WorkerContent) GetMinerPubkey() string {
if m != nil { if m != nil {
return m.WorkerPubkey return m.MinerPubkey
} }
return "" return ""
} }
...@@ -175,9 +175,9 @@ func (m *WorkerContent) GetDevices() []*DeviceInfo { ...@@ -175,9 +175,9 @@ func (m *WorkerContent) GetDevices() []*DeviceInfo {
return nil return nil
} }
func (m *WorkerContent) GetDeviceProof() []byte { func (m *WorkerContent) GetDeviceSignature() []byte {
if m != nil { if m != nil {
return m.DeviceProof return m.DeviceSignature
} }
return nil return nil
} }
...@@ -191,29 +191,30 @@ func init() { ...@@ -191,29 +191,30 @@ func init() {
func init() { proto.RegisterFile("nodemanager/v1/resource.proto", fileDescriptor_462e4441103de524) } func init() { proto.RegisterFile("nodemanager/v1/resource.proto", fileDescriptor_462e4441103de524) }
var fileDescriptor_462e4441103de524 = []byte{ var fileDescriptor_462e4441103de524 = []byte{
// 383 bytes of a gzipped FileDescriptorProto // 393 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x5c, 0x91, 0xcd, 0x6a, 0xdb, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x5c, 0x92, 0xcf, 0x6e, 0x9b, 0x40,
0x14, 0x85, 0x91, 0x6c, 0xda, 0x7a, 0xfc, 0x07, 0x5a, 0x09, 0xd3, 0x52, 0xd7, 0xdd, 0x78, 0x53, 0x10, 0xc6, 0x05, 0xb6, 0xda, 0x7a, 0xfd, 0xaf, 0xe2, 0x84, 0xac, 0x56, 0x75, 0x7d, 0x72, 0x0f,
0x09, 0xb5, 0x5d, 0xb9, 0x3b, 0xb7, 0x50, 0x4a, 0xb1, 0x2b, 0x4c, 0x71, 0x4c, 0x30, 0x18, 0xfd, 0x05, 0xd1, 0xf6, 0xe4, 0xde, 0xdc, 0x4a, 0x55, 0x55, 0xd9, 0x45, 0xb4, 0x72, 0xac, 0xc8, 0x92,
0x5c, 0x2b, 0xc2, 0xd6, 0x5c, 0x31, 0x1a, 0xc9, 0xe8, 0x21, 0xb2, 0xcd, 0x03, 0x64, 0x99, 0x47, 0xb5, 0xc0, 0x84, 0x20, 0x9b, 0x1d, 0xb4, 0x2c, 0x44, 0x3c, 0x47, 0xa4, 0x3c, 0x40, 0x8e, 0x79,
0x09, 0xe4, 0x25, 0xb2, 0xcc, 0x53, 0x04, 0x8d, 0x14, 0x79, 0x94, 0x9d, 0xce, 0x77, 0x8f, 0xce, 0x94, 0x48, 0x79, 0x89, 0x1c, 0xf3, 0x14, 0x11, 0x0b, 0xb6, 0x21, 0x37, 0xbe, 0xdf, 0x7c, 0xfb,
0xdc, 0x99, 0x43, 0x3e, 0x50, 0xf4, 0x21, 0x72, 0xa8, 0x13, 0x00, 0x33, 0x33, 0xcb, 0x64, 0x90, 0xed, 0x0c, 0xb3, 0xe4, 0x3d, 0x43, 0x1f, 0x22, 0xca, 0x68, 0x00, 0xdc, 0xcc, 0x2c, 0x93, 0x43,
0x60, 0xca, 0x3c, 0x30, 0x62, 0x86, 0x1c, 0xb5, 0x81, 0x34, 0x36, 0x32, 0x6b, 0xf2, 0x97, 0x0c, 0x82, 0x29, 0xf7, 0xc0, 0x88, 0x39, 0x0a, 0xd4, 0x06, 0xb5, 0xb2, 0x91, 0x59, 0x93, 0x3f, 0x64,
0x97, 0xe8, 0xc3, 0xa2, 0x24, 0x7f, 0xe8, 0x1e, 0xb5, 0xf7, 0xa4, 0x13, 0xa7, 0xee, 0x31, 0xf4, 0xb8, 0x44, 0x1f, 0x16, 0x25, 0xf9, 0xcd, 0x2e, 0x50, 0x7b, 0x47, 0x3a, 0x71, 0xea, 0xee, 0x43,
0x0e, 0x90, 0xeb, 0xca, 0x58, 0x99, 0x76, 0x56, 0x67, 0xa0, 0x8d, 0xc8, 0x3b, 0xa0, 0x7e, 0x8c, 0x6f, 0x07, 0xb9, 0xae, 0x8c, 0x95, 0x69, 0xc7, 0x39, 0x01, 0x6d, 0x44, 0xde, 0x00, 0xf3, 0x63,
0x21, 0xe5, 0xba, 0x2a, 0x86, 0xb5, 0x9e, 0xdc, 0x28, 0x84, 0xfc, 0x82, 0x2c, 0xf4, 0x40, 0x04, 0x0c, 0x99, 0xd0, 0x55, 0x59, 0x3c, 0xea, 0xc9, 0x8d, 0x42, 0xc8, 0x4f, 0xc8, 0x42, 0x0f, 0x64,
0x7d, 0x24, 0x5d, 0x5f, 0xa8, 0x1d, 0xcf, 0x63, 0xa8, 0xa2, 0x48, 0x89, 0xfe, 0xe7, 0x31, 0x68, 0xd0, 0x07, 0xd2, 0xf5, 0xa5, 0xda, 0x8a, 0x3c, 0x86, 0x2a, 0x8a, 0x94, 0xe8, 0x7f, 0x1e, 0x83,
0x9f, 0x48, 0xaf, 0x32, 0x44, 0xe8, 0xc3, 0xb1, 0xca, 0xab, 0x7e, 0x5a, 0x14, 0x48, 0xb2, 0xc4, 0xf6, 0x91, 0xf4, 0x2a, 0x43, 0x84, 0x3e, 0xec, 0xab, 0xbc, 0xea, 0xd0, 0xa2, 0x40, 0x35, 0x4b,
0x0e, 0x73, 0x22, 0xbd, 0x25, 0x5b, 0xec, 0x02, 0xc9, 0x16, 0x3c, 0x01, 0xd3, 0xdb, 0x63, 0x65, 0x4c, 0x39, 0x8d, 0xf4, 0x56, 0xdd, 0x62, 0x17, 0xa8, 0x6e, 0xc1, 0x2b, 0xe0, 0x7a, 0x7b, 0xac,
0xda, 0xae, 0x2d, 0x05, 0x9a, 0x5c, 0x2b, 0xa4, 0x7f, 0x81, 0xec, 0x00, 0xec, 0x27, 0x52, 0x0e, 0x4c, 0xdb, 0x47, 0x4b, 0x81, 0x26, 0xd7, 0x0a, 0xe9, 0x9f, 0x21, 0xdf, 0x01, 0xff, 0x81, 0x4c,
0x94, 0x6b, 0x9f, 0x49, 0xff, 0x24, 0xc0, 0x2e, 0x4e, 0xdd, 0xf3, 0x45, 0x7b, 0x25, 0xb4, 0x05, 0x00, 0x13, 0xc5, 0xa1, 0x28, 0x64, 0xc0, 0xb7, 0x71, 0xea, 0x9e, 0xe6, 0xec, 0x4a, 0x66, 0x4b,
0xd3, 0xbe, 0x93, 0xb7, 0x65, 0x4a, 0xa2, 0xab, 0xe3, 0xd6, 0xb4, 0xfb, 0x75, 0x64, 0x34, 0x9f, 0xa4, 0x7d, 0x23, 0xaf, 0xcb, 0x8c, 0x44, 0x57, 0xc7, 0xad, 0x69, 0xf7, 0xcb, 0xc8, 0x68, 0xfe,
0xcf, 0x38, 0xdf, 0x76, 0xf5, 0x62, 0x95, 0xf7, 0x61, 0x88, 0x7b, 0xb1, 0x72, 0xaf, 0xde, 0xa7, 0x3c, 0xe3, 0x34, 0xab, 0x73, 0xb0, 0x6a, 0x9f, 0xc8, 0xdb, 0xaa, 0x9b, 0x24, 0x0c, 0x18, 0x15,
0x40, 0xf3, 0x07, 0x85, 0x68, 0x1e, 0x46, 0xaf, 0xd2, 0xe6, 0xfd, 0x55, 0x55, 0x96, 0x5d, 0x74, 0x29, 0x07, 0xd9, 0x74, 0xcf, 0x19, 0x96, 0xfc, 0xdf, 0x01, 0xcf, 0x1f, 0x14, 0xa2, 0x79, 0x18,
0x65, 0x2b, 0x97, 0xff, 0x82, 0x90, 0x5f, 0xa5, 0xae, 0xe1, 0x61, 0x64, 0xa2, 0x9f, 0x27, 0x09, 0xbd, 0x48, 0x9d, 0xf7, 0x9d, 0x6a, 0x65, 0x76, 0xb1, 0x31, 0x5b, 0x39, 0xff, 0x1b, 0x84, 0xe2,
0xa4, 0x49, 0xfd, 0xf1, 0x45, 0x34, 0xea, 0xe1, 0xd1, 0x0c, 0x80, 0x9a, 0x42, 0x98, 0x01, 0x9a, 0x32, 0x75, 0x0d, 0x0f, 0x23, 0x13, 0xfd, 0x3c, 0x49, 0x20, 0x4d, 0x8e, 0x1f, 0x9f, 0xe5, 0x5e,
0xcd, 0xfe, 0x7f, 0x48, 0x32, 0xb3, 0x6e, 0xd5, 0xd6, 0x72, 0xb3, 0xb9, 0x53, 0x07, 0x4b, 0xe9, 0x3d, 0xdc, 0x9b, 0x01, 0x30, 0x53, 0x0a, 0x33, 0x40, 0xb3, 0xf9, 0x0a, 0xbe, 0xd7, 0x64, 0x66,
0xe0, 0xb5, 0x75, 0xdf, 0x00, 0xdb, 0xb5, 0xf5, 0xa8, 0x8e, 0x9a, 0x60, 0xfb, 0xdb, 0x9e, 0x2f, 0xdd, 0xaa, 0xad, 0xe5, 0x7a, 0x7d, 0xa7, 0x0e, 0x96, 0xb5, 0x8b, 0x57, 0xd6, 0x7d, 0x03, 0x6c,
0x80, 0x3b, 0xbe, 0xc3, 0x9d, 0x27, 0x75, 0x28, 0x0d, 0x67, 0xb3, 0xb5, 0xe5, 0xbe, 0x11, 0xa7, 0x56, 0xd6, 0xa3, 0x3a, 0x6a, 0x82, 0xcd, 0x2f, 0x7b, 0xbe, 0x00, 0x41, 0x7d, 0x2a, 0xe8, 0x93,
0x7f, 0x7b, 0x0e, 0x00, 0x00, 0xff, 0xff, 0xb1, 0x9b, 0xeb, 0x03, 0x7d, 0x02, 0x00, 0x00, 0x3a, 0xac, 0x15, 0x67, 0xb3, 0x95, 0xe5, 0xbe, 0x92, 0xb7, 0x7f, 0x7d, 0x0e, 0x00, 0x00, 0xff,
0xff, 0x88, 0x98, 0xc1, 0x27, 0x83, 0x02, 0x00, 0x00,
} }
gen/proto/go/witness/v1/request_response.pb.go
View file @ a934bfb6
...@@ -99,7 +99,7 @@ func (m *WitnessStatusResponse) GetPeers() []string { ...@@ -99,7 +99,7 @@ func (m *WitnessStatusResponse) GetPeers() []string {
type PushProofRequest struct { type PushProofRequest struct {
Workload uint64 `protobuf:"varint,1,opt,name=workload,proto3" json:"workload,omitempty"` Workload uint64 `protobuf:"varint,1,opt,name=workload,proto3" json:"workload,omitempty"`
TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskId string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
NmSignature string `protobuf:"bytes,3,opt,name=nm_signature,json=nmSignature,proto3" json:"nm_signature,omitempty"` ManagerSignature string `protobuf:"bytes,3,opt,name=manager_signature,json=managerSignature,proto3" json:"manager_signature,omitempty"`
ContainerSignature string `protobuf:"bytes,4,opt,name=container_signature,json=containerSignature,proto3" json:"container_signature,omitempty"` ContainerSignature string `protobuf:"bytes,4,opt,name=container_signature,json=containerSignature,proto3" json:"container_signature,omitempty"`
MinerSignature string `protobuf:"bytes,5,opt,name=miner_signature,json=minerSignature,proto3" json:"miner_signature,omitempty"` MinerSignature string `protobuf:"bytes,5,opt,name=miner_signature,json=minerSignature,proto3" json:"miner_signature,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_NoUnkeyedLiteral struct{} `json:"-"`
...@@ -145,9 +145,9 @@ func (m *PushProofRequest) GetTaskId() string { ...@@ -145,9 +145,9 @@ func (m *PushProofRequest) GetTaskId() string {
return "" return ""
} }
func (m *PushProofRequest) GetNmSignature() string { func (m *PushProofRequest) GetManagerSignature() string {
if m != nil { if m != nil {
return m.NmSignature return m.ManagerSignature
} }
return "" return ""
} }
...@@ -465,50 +465,51 @@ func (m *GetWithdrawProofResponse) GetMerkleProof() []string { ...@@ -465,50 +465,51 @@ func (m *GetWithdrawProofResponse) GetMerkleProof() []string {
} }
func init() { func init() {
proto.RegisterType((*WitnessStatusRequest)(nil), "witness.v1.witnessStatusRequest") proto.RegisterType((*WitnessStatusRequest)(nil), "witness.v1.WitnessStatusRequest")
proto.RegisterType((*WitnessStatusResponse)(nil), "witness.v1.witnessStatusResponse") proto.RegisterType((*WitnessStatusResponse)(nil), "witness.v1.WitnessStatusResponse")
proto.RegisterType((*PushProofRequest)(nil), "witness.v1.pushProofRequest") proto.RegisterType((*PushProofRequest)(nil), "witness.v1.PushProofRequest")
proto.RegisterType((*PushProofResponse)(nil), "witness.v1.pushProofResponse") proto.RegisterType((*PushProofResponse)(nil), "witness.v1.PushProofResponse")
proto.RegisterType((*GetMinerProofRequest)(nil), "witness.v1.getMinerProofRequest") proto.RegisterType((*GetMinerProofRequest)(nil), "witness.v1.GetMinerProofRequest")
proto.RegisterType((*GetMinerProofResponse)(nil), "witness.v1.getMinerProofResponse") proto.RegisterType((*GetMinerProofResponse)(nil), "witness.v1.GetMinerProofResponse")
proto.RegisterType((*GetProofRequest)(nil), "witness.v1.getProofRequest") proto.RegisterType((*GetProofRequest)(nil), "witness.v1.GetProofRequest")
proto.RegisterType((*GetProofResponse)(nil), "witness.v1.getProofResponse") proto.RegisterType((*GetProofResponse)(nil), "witness.v1.GetProofResponse")
proto.RegisterType((*GetWithdrawProofRequest)(nil), "witness.v1.getWithdrawProofRequest") proto.RegisterType((*GetWithdrawProofRequest)(nil), "witness.v1.GetWithdrawProofRequest")
proto.RegisterType((*GetWithdrawProofResponse)(nil), "witness.v1.getWithdrawProofResponse") proto.RegisterType((*GetWithdrawProofResponse)(nil), "witness.v1.GetWithdrawProofResponse")
} }
func init() { proto.RegisterFile("witness/v1/request_response.proto", fileDescriptor_fcd71b26d9e7af56) } func init() { proto.RegisterFile("witness/v1/request_response.proto", fileDescriptor_fcd71b26d9e7af56) }
var fileDescriptor_fcd71b26d9e7af56 = []byte{ var fileDescriptor_fcd71b26d9e7af56 = []byte{
// 480 bytes of a gzipped FileDescriptorProto // 483 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x53, 0xc1, 0x6a, 0xdb, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x8c, 0x53, 0xc1, 0x6a, 0xdb, 0x40,
0x10, 0x45, 0x52, 0xe2, 0xd4, 0xe3, 0x92, 0xb8, 0x5b, 0xc7, 0x11, 0x85, 0x82, 0xa3, 0x1e, 0x9a, 0x10, 0xc5, 0x52, 0xe2, 0xd4, 0x13, 0x48, 0x9c, 0xad, 0xe3, 0x88, 0x42, 0xc1, 0x55, 0x0f, 0x0d,
0x4b, 0x25, 0x44, 0x6e, 0x29, 0xf4, 0xe0, 0x4b, 0x08, 0x6d, 0xc0, 0x38, 0x60, 0x87, 0x12, 0x30, 0x94, 0x4a, 0x88, 0xdc, 0x52, 0xe8, 0xc1, 0x17, 0x11, 0xda, 0x80, 0x70, 0xc0, 0x0e, 0x25, 0x60,
0x1b, 0x6b, 0x2a, 0x0b, 0x5b, 0xbb, 0xee, 0xee, 0xca, 0x26, 0xbf, 0xd3, 0x63, 0xbf, 0xa0, 0x1f, 0x36, 0xd6, 0x54, 0x16, 0xb6, 0x76, 0xdd, 0xdd, 0x95, 0x4d, 0x7e, 0xa7, 0xc7, 0x7e, 0x41, 0xbf,
0xd0, 0x53, 0x3f, 0xa3, 0xc7, 0x7e, 0x45, 0xd1, 0x6a, 0x65, 0xd9, 0x2e, 0x71, 0x73, 0xdb, 0x37, 0xa1, 0x87, 0x7e, 0x44, 0x8f, 0xfd, 0x8a, 0xa2, 0xd5, 0xca, 0x8a, 0x5d, 0x92, 0xe6, 0x36, 0x6f,
0xfb, 0xde, 0xbc, 0x7d, 0xc3, 0x0e, 0x9c, 0x2e, 0x13, 0xc5, 0x50, 0xca, 0x60, 0x11, 0x06, 0x02, 0xe6, 0xbd, 0x79, 0x3b, 0xc3, 0x0e, 0xbc, 0x5a, 0xa5, 0x8a, 0xa1, 0x94, 0xfe, 0x32, 0xf0, 0x05,
0xbf, 0x66, 0x28, 0xd5, 0x48, 0xa0, 0x9c, 0x73, 0x26, 0xd1, 0x9f, 0x0b, 0xae, 0x38, 0x01, 0x43, 0x7e, 0xcd, 0x51, 0xaa, 0xb1, 0x40, 0xb9, 0xe0, 0x4c, 0xa2, 0xb7, 0x10, 0x5c, 0x71, 0x02, 0x86,
0xf1, 0x17, 0xa1, 0xd7, 0x86, 0x96, 0x41, 0x37, 0x8a, 0xaa, 0x4c, 0xf6, 0x0b, 0x89, 0xf7, 0x09, 0xe2, 0x2d, 0x03, 0xb7, 0x0b, 0x9d, 0x51, 0x89, 0xae, 0x14, 0x55, 0xb9, 0x1c, 0x94, 0x12, 0xf7,
0x8e, 0xb7, 0xea, 0x45, 0x0b, 0xf2, 0x1a, 0x4a, 0xf9, 0x28, 0x89, 0x5c, 0xab, 0x63, 0x9d, 0xd5, 0x13, 0x1c, 0x6f, 0xe5, 0xcb, 0x16, 0xe4, 0x25, 0x54, 0xf2, 0x71, 0x1a, 0x3b, 0x8d, 0x5e, 0xe3,
0xfb, 0x75, 0x53, 0xb9, 0x8a, 0x48, 0x0b, 0xf6, 0xe7, 0x88, 0x42, 0xba, 0x76, 0xc7, 0x39, 0xab, 0xb4, 0x35, 0x68, 0x99, 0xcc, 0x45, 0x4c, 0x3a, 0xb0, 0xbb, 0x40, 0x14, 0xd2, 0xb1, 0x7a, 0xf6,
0xf7, 0x0b, 0xe0, 0xfd, 0xb4, 0xa0, 0x39, 0xcf, 0xe4, 0xa4, 0x27, 0x38, 0xff, 0x62, 0x2c, 0xc8, 0x69, 0x6b, 0x50, 0x02, 0xf7, 0x57, 0x03, 0xda, 0x51, 0x2e, 0xa7, 0x91, 0xe0, 0xfc, 0x8b, 0xb1,
0x2b, 0x78, 0xb6, 0xe4, 0x62, 0x3a, 0xe3, 0xb4, 0xe8, 0xb3, 0xd7, 0x5f, 0x61, 0x72, 0x02, 0x07, 0x20, 0x2f, 0xe0, 0xd9, 0x8a, 0x8b, 0xd9, 0x9c, 0xd3, 0xb2, 0xcf, 0xce, 0x60, 0x8d, 0xc9, 0x09,
0x8a, 0xca, 0x69, 0x6e, 0x61, 0x6b, 0x8b, 0x5a, 0x0e, 0xaf, 0x22, 0x72, 0x0a, 0xcf, 0x59, 0x3a, 0xec, 0x29, 0x2a, 0x67, 0x85, 0x85, 0xa5, 0x2d, 0x9a, 0x05, 0xbc, 0x88, 0xc9, 0x5b, 0x38, 0xca,
0x92, 0x49, 0xcc, 0xa8, 0xca, 0x04, 0xba, 0x8e, 0xbe, 0x6d, 0xb0, 0xf4, 0xa6, 0x2c, 0x91, 0x00, 0x28, 0xa3, 0x09, 0x8a, 0xb1, 0x4c, 0x13, 0x46, 0x55, 0x2e, 0xd0, 0xb1, 0x35, 0xa5, 0x6d, 0x0a,
0x5e, 0x8e, 0x39, 0x53, 0x34, 0x61, 0x28, 0xd6, 0x98, 0x7b, 0x9a, 0x49, 0x56, 0x57, 0x95, 0xe0, 0x57, 0x55, 0x9e, 0xf8, 0xf0, 0x7c, 0xc2, 0x99, 0xa2, 0x29, 0xdb, 0xa0, 0xef, 0x68, 0x3a, 0x59,
0x2d, 0x1c, 0xa5, 0x5b, 0xe4, 0x7d, 0x4d, 0x3e, 0x4c, 0x37, 0x88, 0x5e, 0x00, 0x2f, 0xd6, 0x52, 0x97, 0x6a, 0xc1, 0x1b, 0x38, 0xcc, 0xb6, 0xc8, 0xbb, 0x9a, 0x7c, 0x90, 0x6d, 0x10, 0x5d, 0x1f,
0x98, 0x81, 0xec, 0x88, 0xe1, 0x7d, 0x80, 0x56, 0x8c, 0xea, 0x3a, 0xef, 0xb2, 0x11, 0xbd, 0x09, 0x8e, 0xee, 0xcd, 0x63, 0x56, 0xf3, 0xc8, 0x40, 0xee, 0x07, 0xe8, 0x84, 0xa8, 0x2e, 0x8b, 0x2e,
0xce, 0x43, 0x5a, 0x4e, 0x2f, 0x3f, 0xe6, 0x73, 0xd3, 0x66, 0x26, 0x6e, 0x01, 0xbc, 0x8f, 0x70, 0x1b, 0x4b, 0x68, 0x83, 0x7d, 0x97, 0x55, 0x7b, 0x2c, 0xc2, 0x62, 0x83, 0xda, 0xcc, 0x0c, 0x5e,
0xbc, 0xa5, 0xff, 0xbf, 0x29, 0x69, 0x43, 0x8d, 0xa6, 0x3c, 0x63, 0xaa, 0x1c, 0x5d, 0x81, 0xbc, 0x02, 0xf7, 0x23, 0x1c, 0x6f, 0xe9, 0xff, 0x6f, 0x4a, 0xba, 0xd0, 0xa4, 0x19, 0xcf, 0x99, 0xaa,
0x37, 0x70, 0x14, 0xa3, 0xda, 0xfd, 0x0e, 0xcf, 0x87, 0x66, 0x45, 0x7a, 0x42, 0xc2, 0x73, 0x38, 0x96, 0x58, 0x22, 0xf7, 0x35, 0x1c, 0x86, 0xa8, 0x1e, 0x7f, 0x87, 0xeb, 0x41, 0xbb, 0x26, 0x3d,
0x89, 0x51, 0x0d, 0x13, 0x35, 0x89, 0x04, 0x5d, 0x6e, 0x34, 0x77, 0xe1, 0x80, 0x46, 0x91, 0x40, 0x61, 0xc2, 0x33, 0x38, 0x09, 0x51, 0x8d, 0x52, 0x35, 0x8d, 0x05, 0x5d, 0x6d, 0x34, 0x77, 0x60,
0x29, 0x8d, 0x41, 0x09, 0x3d, 0x06, 0xee, 0xbf, 0x22, 0x63, 0xf6, 0xa8, 0xea, 0xb1, 0x5c, 0xa4, 0x8f, 0xc6, 0xb1, 0x40, 0x29, 0x8d, 0x41, 0x05, 0x5d, 0x06, 0xce, 0xbf, 0x22, 0x63, 0xf6, 0xa0,
0x03, 0x8d, 0x14, 0xc5, 0x74, 0x86, 0xba, 0x91, 0xeb, 0xe8, 0x8f, 0xb7, 0x5e, 0xea, 0xfe, 0xb0, 0xea, 0xa1, 0xb9, 0x48, 0x0f, 0xf6, 0x33, 0x14, 0xb3, 0x39, 0xea, 0x46, 0x8e, 0xad, 0xbf, 0xe0,
0xe0, 0x70, 0xcc, 0x53, 0xbf, 0xfa, 0xf7, 0xdd, 0x96, 0x79, 0x65, 0xe9, 0xdb, 0xcb, 0x37, 0xa3, 0xfd, 0x54, 0xff, 0x47, 0x03, 0x0e, 0x26, 0x3c, 0xf3, 0xea, 0x0b, 0xe8, 0x77, 0xcc, 0x2b, 0x2b,
0x67, 0x7d, 0xbe, 0x8c, 0x13, 0x35, 0xc9, 0xee, 0xfd, 0x31, 0x4f, 0x03, 0x1e, 0x3d, 0x48, 0x89, 0xdf, 0xa8, 0xb8, 0x91, 0xa8, 0xf1, 0x39, 0x4c, 0x52, 0x35, 0xcd, 0x6f, 0xbd, 0x09, 0xcf, 0x7c,
0x99, 0x5c, 0x1d, 0xde, 0xe9, 0xfd, 0x19, 0xf3, 0x59, 0x10, 0x23, 0x0b, 0x34, 0x08, 0x62, 0x1e, 0x1e, 0xdf, 0x49, 0x89, 0xb9, 0x5c, 0x07, 0xef, 0xf4, 0x25, 0x4d, 0xf8, 0xdc, 0x4f, 0x90, 0xf9,
0x54, 0x1b, 0xf7, 0xde, 0x1c, 0x17, 0xe1, 0x37, 0xdb, 0x19, 0xde, 0xde, 0x7e, 0xb7, 0x61, 0x68, 0x1a, 0xf8, 0x09, 0xf7, 0xeb, 0xdb, 0x7b, 0x6f, 0xc2, 0x65, 0xf0, 0xcd, 0xb2, 0x47, 0xd7, 0xd7,
0x3c, 0x07, 0xe1, 0xaf, 0x15, 0xb8, 0x1b, 0x84, 0xbf, 0xed, 0x76, 0x05, 0xee, 0x2e, 0x7b, 0xdd, 0xdf, 0x2d, 0x30, 0xf7, 0xe4, 0x0d, 0x83, 0x9f, 0x6b, 0x70, 0x33, 0x0c, 0x7e, 0x5b, 0xdd, 0x1a,
0x6b, 0x54, 0x34, 0xa2, 0x8a, 0xfe, 0xb1, 0x1b, 0xe6, 0xe2, 0xe2, 0x62, 0x10, 0xde, 0xd7, 0xb4, 0xdc, 0x84, 0x51, 0xff, 0x12, 0x15, 0x8d, 0xa9, 0xa2, 0x7f, 0xac, 0x7d, 0x53, 0x38, 0x3f, 0x1f,
0xcb, 0xf9, 0xdf, 0x00, 0x00, 0x00, 0xff, 0xff, 0x43, 0x72, 0x70, 0x2a, 0xd7, 0x03, 0x00, 0x00, 0x06, 0xb7, 0x4d, 0xed, 0x72, 0xf6, 0x37, 0x00, 0x00, 0xff, 0xff, 0x6c, 0xf5, 0x84, 0x7f, 0xe1,
0x03, 0x00, 0x00,
} }
gen/proto/go/witness/v1/service.pb.go
View file @ a934bfb6
...@@ -23,27 +23,26 @@ const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package ...@@ -23,27 +23,26 @@ const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
func init() { proto.RegisterFile("witness/v1/service.proto", fileDescriptor_687af857651c0e7f) } func init() { proto.RegisterFile("witness/v1/service.proto", fileDescriptor_687af857651c0e7f) }
var fileDescriptor_687af857651c0e7f = []byte{ var fileDescriptor_687af857651c0e7f = []byte{
// 337 bytes of a gzipped FileDescriptorProto // 335 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x92, 0xc1, 0x4a, 0xf3, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x92, 0xc1, 0x4a, 0xfb, 0x40,
0x10, 0xc7, 0xbf, 0xa6, 0xf0, 0xa1, 0xab, 0x2d, 0x92, 0x83, 0x48, 0xad, 0x60, 0xd5, 0xab, 0x59, 0x10, 0xc6, 0xff, 0x4d, 0xe1, 0x8f, 0xae, 0xb6, 0x48, 0x0e, 0x22, 0xb5, 0x82, 0x55, 0xaf, 0x66,
0x56, 0x6f, 0xf5, 0xd6, 0xcb, 0x82, 0x50, 0x08, 0x0a, 0x69, 0x91, 0x42, 0x49, 0xd3, 0x31, 0x0d, 0x59, 0xbd, 0xd5, 0x5b, 0x2f, 0x0b, 0x42, 0x21, 0x28, 0xa4, 0x45, 0x0a, 0x25, 0x4d, 0xc7, 0x36,
0xd8, 0x6c, 0xdd, 0x9d, 0xa4, 0xf8, 0x3a, 0x1e, 0x3d, 0x79, 0xf2, 0x21, 0x7c, 0x0c, 0x8f, 0x3e, 0x60, 0xb3, 0x75, 0x77, 0x92, 0xe2, 0xeb, 0x78, 0xf4, 0xe4, 0xc9, 0x87, 0xf0, 0x31, 0x3c, 0xfa,
0x85, 0xd8, 0xdd, 0xa4, 0x49, 0xa8, 0xbd, 0xcd, 0xcc, 0xff, 0x3f, 0xbf, 0x19, 0x98, 0x21, 0x47, 0x14, 0x62, 0x77, 0xb3, 0x6d, 0x42, 0xed, 0x6d, 0x67, 0xbe, 0x6f, 0x7e, 0x33, 0xf0, 0x2d, 0x39,
0xcb, 0x08, 0x63, 0x50, 0x8a, 0xa6, 0x8c, 0x2a, 0x90, 0x69, 0x14, 0x80, 0xb3, 0x90, 0x02, 0x85, 0x5a, 0xc4, 0x98, 0x80, 0x52, 0x34, 0x63, 0x54, 0x81, 0xcc, 0xe2, 0x08, 0xbc, 0xb9, 0x14, 0x28,
0x4d, 0x8c, 0xe2, 0xa4, 0xac, 0xd5, 0x29, 0xb8, 0x24, 0x3c, 0x27, 0xa0, 0x70, 0x2c, 0x41, 0x2d, 0x5c, 0x62, 0x14, 0x2f, 0x63, 0x8d, 0xd6, 0x9a, 0x4b, 0xc2, 0x73, 0x0a, 0x0a, 0x87, 0x12, 0xd4,
0x44, 0xac, 0x8c, 0xfd, 0xea, 0xa3, 0x4e, 0x9a, 0xc6, 0x75, 0xaf, 0x39, 0xb6, 0x47, 0x1a, 0x03, 0x5c, 0x24, 0xca, 0xd8, 0xaf, 0x3e, 0xaa, 0xa4, 0xde, 0xd3, 0xae, 0x7b, 0xcd, 0x71, 0x03, 0x52,
0x53, 0x41, 0x1f, 0x13, 0x65, 0x9f, 0x3a, 0x6b, 0x66, 0x16, 0x6a, 0xe9, 0x4e, 0x43, 0x5b, 0x9d, 0xcb, 0x3b, 0x18, 0x62, 0xaa, 0xdc, 0x53, 0x6f, 0xc5, 0xf4, 0x0a, 0xd2, 0x9d, 0x86, 0x36, 0x5a,
0x2d, 0x0e, 0x3d, 0xee, 0xec, 0x9f, 0x7d, 0x4b, 0x76, 0xdd, 0x44, 0xcd, 0x5c, 0x29, 0xc4, 0xa3, 0x5b, 0x1c, 0x7a, 0xdd, 0xd9, 0x3f, 0xf7, 0x96, 0xec, 0xfa, 0xa9, 0x9a, 0xfa, 0x52, 0x88, 0x47,
0xdd, 0x2e, 0x76, 0x2c, 0xb2, 0x72, 0xc6, 0x3b, 0xf9, 0x43, 0xcd, 0x59, 0x1e, 0x69, 0x70, 0xc0, 0xb7, 0xb9, 0x3e, 0x61, 0xdb, 0x39, 0xef, 0xe4, 0x0f, 0xd5, 0xb2, 0x02, 0x52, 0xe3, 0x80, 0xdd,
0x7e, 0x14, 0x83, 0xd4, 0xbc, 0xd2, 0x8e, 0x61, 0x51, 0xda, 0xb8, 0x63, 0xc5, 0x91, 0x73, 0x39, 0x38, 0x01, 0xa9, 0x79, 0x85, 0x1b, 0x0b, 0xd2, 0xc6, 0x1b, 0x4b, 0x0e, 0xcb, 0xe5, 0x64, 0x87,
0xd9, 0xe1, 0x80, 0x1a, 0x79, 0x5c, 0x69, 0x28, 0xd1, 0xda, 0x9b, 0xc5, 0x1c, 0x34, 0x26, 0x07, 0x03, 0x6a, 0xe4, 0x71, 0x69, 0xa0, 0x40, 0x6b, 0x6e, 0x16, 0x2d, 0x68, 0x48, 0x0e, 0x38, 0x60,
0x1c, 0x70, 0x10, 0xe1, 0x6c, 0x2a, 0xfd, 0xa5, 0x06, 0x9e, 0x57, 0x7a, 0x4a, 0x6a, 0x06, 0xbe, 0x2f, 0xc6, 0xe9, 0x58, 0x86, 0x0b, 0x0d, 0x3c, 0x2f, 0xcd, 0x14, 0xd4, 0x1c, 0x7c, 0xb1, 0xdd,
0xd8, 0x6e, 0xca, 0x06, 0xf4, 0xde, 0x6b, 0xa4, 0x19, 0x88, 0x79, 0xc1, 0xdd, 0xdb, 0x37, 0x17, 0x94, 0x2f, 0xe8, 0xbc, 0x57, 0x48, 0x3d, 0x12, 0xb3, 0x35, 0x77, 0x67, 0xdf, 0x24, 0xe8, 0xff,
0x74, 0x7f, 0x2f, 0xeb, 0xd6, 0x1e, 0x78, 0x18, 0xe1, 0x2c, 0x99, 0x38, 0x81, 0x98, 0x53, 0x31, 0x26, 0xeb, 0x57, 0x1e, 0xf8, 0x24, 0xc6, 0x69, 0x3a, 0xf2, 0x22, 0x31, 0xa3, 0x62, 0xfc, 0xa2,
0x7d, 0x51, 0x0a, 0x12, 0x95, 0x07, 0x97, 0xab, 0xfb, 0x07, 0xe2, 0x89, 0x86, 0x10, 0xd3, 0x55, 0x14, 0xa4, 0xca, 0x3e, 0x2e, 0x97, 0xf9, 0x47, 0xe2, 0x89, 0x4e, 0x20, 0xa1, 0xcb, 0x82, 0x4e,
0x42, 0x43, 0x41, 0xd7, 0x1f, 0x73, 0x63, 0xc2, 0x94, 0xbd, 0x5a, 0xf5, 0xc1, 0x70, 0xf8, 0x66, 0x04, 0x5d, 0xfd, 0x98, 0x1b, 0xf3, 0xcc, 0xd8, 0xab, 0x53, 0xed, 0xf5, 0xfb, 0x6f, 0x0e, 0x31,
0x11, 0xf3, 0x16, 0x8e, 0xc7, 0x3e, 0xf3, 0x64, 0xe4, 0xb1, 0x2f, 0xeb, 0x70, 0x9d, 0x8c, 0xb8, 0xc9, 0x7a, 0x01, 0xfb, 0xb4, 0xc5, 0x20, 0x60, 0x5f, 0xce, 0xe1, 0xaa, 0x18, 0x70, 0xbf, 0xd3,
0xdb, 0xeb, 0x03, 0xfa, 0x53, 0x1f, 0xfd, 0x6f, 0x6b, 0xcf, 0x08, 0xdd, 0xae, 0xc7, 0x26, 0xff, 0x05, 0x0c, 0xc7, 0x21, 0x86, 0xdf, 0xce, 0x9e, 0x11, 0xda, 0xed, 0x80, 0x8d, 0xfe, 0x2f, 0xb7,
0x57, 0x53, 0xae, 0x7f, 0x02, 0x00, 0x00, 0xff, 0xff, 0xd8, 0x30, 0x98, 0x73, 0xbd, 0x02, 0x00, 0x5c, 0xff, 0x04, 0x00, 0x00, 0xff, 0xff, 0xcf, 0x7f, 0x10, 0x74, 0xbd, 0x02, 0x00, 0x00,
0x00,
} }
gen/proto/go/witness/v1/service_grpc.pb.go
View file @ a934bfb6
...@@ -39,7 +39,7 @@ func NewWitnessServiceClient(cc grpc.ClientConnInterface) WitnessServiceClient { ...@@ -39,7 +39,7 @@ func NewWitnessServiceClient(cc grpc.ClientConnInterface) WitnessServiceClient {
func (c *witnessServiceClient) WitnessStatus(ctx context.Context, in *WitnessStatusRequest, opts ...grpc.CallOption) (*WitnessStatusResponse, error) { func (c *witnessServiceClient) WitnessStatus(ctx context.Context, in *WitnessStatusRequest, opts ...grpc.CallOption) (*WitnessStatusResponse, error) {
out := new(WitnessStatusResponse) out := new(WitnessStatusResponse)
err := c.cc.Invoke(ctx, "/witness.v1.witnessService/WitnessStatus", in, out, opts...) err := c.cc.Invoke(ctx, "/witness.v1.WitnessService/WitnessStatus", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -48,7 +48,7 @@ func (c *witnessServiceClient) WitnessStatus(ctx context.Context, in *WitnessSta ...@@ -48,7 +48,7 @@ func (c *witnessServiceClient) WitnessStatus(ctx context.Context, in *WitnessSta
func (c *witnessServiceClient) PushProof(ctx context.Context, in *PushProofRequest, opts ...grpc.CallOption) (*PushProofResponse, error) { func (c *witnessServiceClient) PushProof(ctx context.Context, in *PushProofRequest, opts ...grpc.CallOption) (*PushProofResponse, error) {
out := new(PushProofResponse) out := new(PushProofResponse)
err := c.cc.Invoke(ctx, "/witness.v1.witnessService/PushProof", in, out, opts...) err := c.cc.Invoke(ctx, "/witness.v1.WitnessService/PushProof", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -57,7 +57,7 @@ func (c *witnessServiceClient) PushProof(ctx context.Context, in *PushProofReque ...@@ -57,7 +57,7 @@ func (c *witnessServiceClient) PushProof(ctx context.Context, in *PushProofReque
func (c *witnessServiceClient) GetMinerProof(ctx context.Context, in *GetMinerProofRequest, opts ...grpc.CallOption) (*GetMinerProofResponse, error) { func (c *witnessServiceClient) GetMinerProof(ctx context.Context, in *GetMinerProofRequest, opts ...grpc.CallOption) (*GetMinerProofResponse, error) {
out := new(GetMinerProofResponse) out := new(GetMinerProofResponse)
err := c.cc.Invoke(ctx, "/witness.v1.witnessService/GetMinerProof", in, out, opts...) err := c.cc.Invoke(ctx, "/witness.v1.WitnessService/GetMinerProof", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -66,7 +66,7 @@ func (c *witnessServiceClient) GetMinerProof(ctx context.Context, in *GetMinerPr ...@@ -66,7 +66,7 @@ func (c *witnessServiceClient) GetMinerProof(ctx context.Context, in *GetMinerPr
func (c *witnessServiceClient) GetProof(ctx context.Context, in *GetProofRequest, opts ...grpc.CallOption) (*GetProofResponse, error) { func (c *witnessServiceClient) GetProof(ctx context.Context, in *GetProofRequest, opts ...grpc.CallOption) (*GetProofResponse, error) {
out := new(GetProofResponse) out := new(GetProofResponse)
err := c.cc.Invoke(ctx, "/witness.v1.witnessService/GetProof", in, out, opts...) err := c.cc.Invoke(ctx, "/witness.v1.WitnessService/GetProof", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -75,7 +75,7 @@ func (c *witnessServiceClient) GetProof(ctx context.Context, in *GetProofRequest ...@@ -75,7 +75,7 @@ func (c *witnessServiceClient) GetProof(ctx context.Context, in *GetProofRequest
func (c *witnessServiceClient) GetWithdrawProof(ctx context.Context, in *GetWithdrawProofRequest, opts ...grpc.CallOption) (*GetWithdrawProofResponse, error) { func (c *witnessServiceClient) GetWithdrawProof(ctx context.Context, in *GetWithdrawProofRequest, opts ...grpc.CallOption) (*GetWithdrawProofResponse, error) {
out := new(GetWithdrawProofResponse) out := new(GetWithdrawProofResponse)
err := c.cc.Invoke(ctx, "/witness.v1.witnessService/GetWithdrawProof", in, out, opts...) err := c.cc.Invoke(ctx, "/witness.v1.WitnessService/GetWithdrawProof", in, out, opts...)
if err != nil { if err != nil {
return nil, err return nil, err
} }
...@@ -136,7 +136,7 @@ func _WitnessService_WitnessStatus_Handler(srv interface{}, ctx context.Context, ...@@ -136,7 +136,7 @@ func _WitnessService_WitnessStatus_Handler(srv interface{}, ctx context.Context,
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: "/witness.v1.witnessService/WitnessStatus", FullMethod: "/witness.v1.WitnessService/WitnessStatus",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WitnessServiceServer).WitnessStatus(ctx, req.(*WitnessStatusRequest)) return srv.(WitnessServiceServer).WitnessStatus(ctx, req.(*WitnessStatusRequest))
...@@ -154,7 +154,7 @@ func _WitnessService_PushProof_Handler(srv interface{}, ctx context.Context, dec ...@@ -154,7 +154,7 @@ func _WitnessService_PushProof_Handler(srv interface{}, ctx context.Context, dec
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: "/witness.v1.witnessService/PushProof", FullMethod: "/witness.v1.WitnessService/PushProof",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WitnessServiceServer).PushProof(ctx, req.(*PushProofRequest)) return srv.(WitnessServiceServer).PushProof(ctx, req.(*PushProofRequest))
...@@ -172,7 +172,7 @@ func _WitnessService_GetMinerProof_Handler(srv interface{}, ctx context.Context, ...@@ -172,7 +172,7 @@ func _WitnessService_GetMinerProof_Handler(srv interface{}, ctx context.Context,
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: "/witness.v1.witnessService/GetMinerProof", FullMethod: "/witness.v1.WitnessService/GetMinerProof",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WitnessServiceServer).GetMinerProof(ctx, req.(*GetMinerProofRequest)) return srv.(WitnessServiceServer).GetMinerProof(ctx, req.(*GetMinerProofRequest))
...@@ -190,7 +190,7 @@ func _WitnessService_GetProof_Handler(srv interface{}, ctx context.Context, dec ...@@ -190,7 +190,7 @@ func _WitnessService_GetProof_Handler(srv interface{}, ctx context.Context, dec
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: "/witness.v1.witnessService/GetProof", FullMethod: "/witness.v1.WitnessService/GetProof",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WitnessServiceServer).GetProof(ctx, req.(*GetProofRequest)) return srv.(WitnessServiceServer).GetProof(ctx, req.(*GetProofRequest))
...@@ -208,7 +208,7 @@ func _WitnessService_GetWithdrawProof_Handler(srv interface{}, ctx context.Conte ...@@ -208,7 +208,7 @@ func _WitnessService_GetWithdrawProof_Handler(srv interface{}, ctx context.Conte
} }
info := &grpc.UnaryServerInfo{ info := &grpc.UnaryServerInfo{
Server: srv, Server: srv,
FullMethod: "/witness.v1.witnessService/GetWithdrawProof", FullMethod: "/witness.v1.WitnessService/GetWithdrawProof",
} }
handler := func(ctx context.Context, req interface{}) (interface{}, error) { handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(WitnessServiceServer).GetWithdrawProof(ctx, req.(*GetWithdrawProofRequest)) return srv.(WitnessServiceServer).GetWithdrawProof(ctx, req.(*GetWithdrawProofRequest))
...@@ -220,7 +220,7 @@ func _WitnessService_GetWithdrawProof_Handler(srv interface{}, ctx context.Conte ...@@ -220,7 +220,7 @@ func _WitnessService_GetWithdrawProof_Handler(srv interface{}, ctx context.Conte
// It's only intended for direct use with grpc.RegisterService, // It's only intended for direct use with grpc.RegisterService,
// and not to be introspected or modified (even as a copy) // and not to be introspected or modified (even as a copy)
var WitnessService_ServiceDesc = grpc.ServiceDesc{ var WitnessService_ServiceDesc = grpc.ServiceDesc{
ServiceName: "witness.v1.witnessService", ServiceName: "witness.v1.WitnessService",
HandlerType: (*WitnessServiceServer)(nil), HandlerType: (*WitnessServiceServer)(nil),
Methods: []grpc.MethodDesc{ Methods: []grpc.MethodDesc{
{ {
......
nodemanager/nodemanager/v1/request_response.proto
View file @ a934bfb6
...@@ -28,15 +28,10 @@ message ManagerMessage { ...@@ -28,15 +28,10 @@ message ManagerMessage {
} }
} }
enum TaskType {
SystemTask = 0;
UserTask = 1;
CustomTask = 2;
}
message GoodbyeMessage { message GoodbyeMessage {
string reason = 1; string reason = 1;
} }
message HeartbeatRequest { message HeartbeatRequest {
uint64 timestamp = 1; uint64 timestamp = 1;
} }
...@@ -49,7 +44,6 @@ message StatusRequest { ...@@ -49,7 +44,6 @@ message StatusRequest {
} }
message DeviceUsageRequest { message DeviceUsageRequest {
} }
message DeviceUsageResponse { message DeviceUsageResponse {
...@@ -74,20 +68,20 @@ message StatusResponse { ...@@ -74,20 +68,20 @@ message StatusResponse {
message PushTaskMessage { message PushTaskMessage {
string task_id = 1; string task_id = 1;
TaskType task_type = 2; base.v1.TaskType task_type = 2;
uint64 work_load = 3; uint64 workload = 3;
string task_cmd = 4; // string task_cmd = 4; //
bytes task_param = 5; bytes task_param = 5;
} }
// 容器签名 (task_id+hash(task_param)+hash(task_result)) // container_signature = sign(hash(task_id+hash(task_param)+hash(task_result)))
// 矿工签名 (task_id+hash(task_param)+hash(task_result)) // miner_signature = sign(hash((task_id+hash(task_param)+hash(task_result)))
// nodemanager签名 (task_id+hash(task_param)+hash(task_result)+docker_signature+miner_signature+workload) // manager_signature = sign(hash((task_id+hash(task_param)+hash(task_result)+container_signature+miner_signature+workload))
message SubmitTaskResult { message SubmitTaskResult {
string task_id = 1; string task_id = 1;
bytes task_proof = 2; // 容器签名 bytes container_signature = 2; // 容器签名
bytes worker_signature = 3; // worker 签名 bytes miner_signature = 3; // worker 签名
bytes task_result = 4; // 任务结果 bytes task_result = 4; // 任务结果
} }
...@@ -96,20 +90,16 @@ message ProofTaskResult { ...@@ -96,20 +90,16 @@ message ProofTaskResult {
bytes manager_signature = 2; // nodemanager 签名 bytes manager_signature = 2; // nodemanager 签名
} }
message DispatchTaskRequest { message DispatchTaskRequest {
string task_id = 1; base.v1.TaskContent task_data = 1;
TaskType task_type = 2; string miner = 2;
base.v1.TaskContent task_data = 3;
string worker = 4;
} }
message DispatchTaskResponse { message DispatchTaskResponse {
string task_id = 1; string task_id = 1;
string worker_id = 2; string miner = 2;
} }
message ManagerListRequest { message ManagerListRequest {
} }
......
nodemanager/nodemanager/v1/resource.proto
View file @ a934bfb6
...@@ -16,7 +16,7 @@ message DeviceInfo { ...@@ -16,7 +16,7 @@ message DeviceInfo {
} }
message WorkerContent { message WorkerContent {
string worker_pubkey = 1; string miner_pubkey = 1;
repeated DeviceInfo devices = 2; repeated DeviceInfo devices = 2;
bytes device_proof = 3; // 由测试程序对设备信息进行签名 bytes device_signature = 3; // 由测试程序对设备信息进行签名
} }
\ No newline at end of file
witness/witness/v1/request_response.proto
View file @ a934bfb6
...@@ -2,49 +2,49 @@ syntax = "proto3"; ...@@ -2,49 +2,49 @@ syntax = "proto3";
package witness.v1; package witness.v1;
message witnessStatusRequest { message WitnessStatusRequest {
} }
message witnessStatusResponse { message WitnessStatusResponse {
string witness_id = 1; string witness_id = 1;
repeated string peers = 2; repeated string peers = 2;
} }
message pushProofRequest { message PushProofRequest {
uint64 workload = 1; uint64 workload = 1;
string task_id = 2; string task_id = 2;
string nm_signature = 3; string manager_signature = 3;
string container_signature = 4; string container_signature = 4;
string miner_signature = 5; string miner_signature = 5;
} }
message pushProofResponse { message PushProofResponse {
uint64 workload = 1; uint64 workload = 1;
} }
message getMinerProofRequest { message GetMinerProofRequest {
string ymd = 1; string ymd = 1;
string miner = 2; string miner = 2;
} }
message getMinerProofResponse { message GetMinerProofResponse {
uint64 workload = 1; uint64 workload = 1;
string amount = 2; string amount = 2;
} }
message getProofRequest { message GetProofRequest {
string ymd = 1; string ymd = 1;
} }
message getProofResponse { message GetProofResponse {
uint64 workload = 1; uint64 workload = 1;
} }
message getWithdrawProofRequest { message GetWithdrawProofRequest {
string address = 1; string address = 1;
} }
message getWithdrawProofResponse { message GetWithdrawProofResponse {
string address = 1; string address = 1;
string amount = 2; string amount = 2;
repeated string merkleProof = 3; repeated string merkleProof = 3;
......
witness/witness/v1/service.proto
View file @ a934bfb6
...@@ -5,12 +5,12 @@ package witness.v1; ...@@ -5,12 +5,12 @@ package witness.v1;
import "witness/v1/request_response.proto"; import "witness/v1/request_response.proto";
service witnessService { service WitnessService {
rpc WitnessStatus(witnessStatusRequest) returns (witnessStatusResponse) {}; // witness status rpc WitnessStatus(WitnessStatusRequest) returns (WitnessStatusResponse) {}; // witness status
rpc PushProof(pushProofRequest) returns (pushProofResponse) {}; // miner push proof rpc PushProof(PushProofRequest) returns (PushProofResponse) {}; // miner push proof
rpc GetMinerProof(getMinerProofRequest) returns (getMinerProofResponse) {}; // proof of a miner per day rpc GetMinerProof(GetMinerProofRequest) returns (GetMinerProofResponse) {}; // proof of a miner per day
rpc GetProof(getProofRequest) returns (getProofResponse) {}; // proof per day rpc GetProof(GetProofRequest) returns (GetProofResponse) {}; // proof per day
rpc GetWithdrawProof(getWithdrawProofRequest) returns (getWithdrawProofResponse) {}; // get merkle proof of withdraw token rpc GetWithdrawProof(GetWithdrawProofRequest) returns (GetWithdrawProofResponse) {}; // get merkle proof of withdraw token
} }
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