Commit a053bd1e authored by vicotor's avatar vicotor

update protocol

;
parent 01297bbd
...@@ -31,6 +31,8 @@ message TaskContent { ...@@ -31,6 +31,8 @@ message TaskContent {
string task_uid = 7; string task_uid = 7;
string task_fee = 8; string task_fee = 8;
// todo: add workload and container publickey // todo: add workload and container publickey
int64 task_workload = 9;
bytes container_pubkey = 10;
} }
message TaskResponse { message TaskResponse {
...@@ -38,9 +40,6 @@ message TaskResponse { ...@@ -38,9 +40,6 @@ message TaskResponse {
bytes task_result = 2; bytes task_result = 2;
string task_uid = 3; string task_uid = 3;
string task_fee = 4; string task_fee = 4;
} bool task_is_succeed = 5;
string task_error = 6;
enum WorkerStatus {
WorkerStatusActive = 0;
WorkerStatusInActive = 1;
} }
\ No newline at end of file
...@@ -78,40 +78,18 @@ func (BillingMethod) EnumDescriptor() ([]byte, []int) { ...@@ -78,40 +78,18 @@ func (BillingMethod) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_91b466c680c1fa25, []int{1} return fileDescriptor_91b466c680c1fa25, []int{1}
} }
type WorkerStatus int32
const (
WorkerStatus_WorkerStatusActive WorkerStatus = 0
WorkerStatus_WorkerStatusInActive WorkerStatus = 1
)
var WorkerStatus_name = map[int32]string{
0: "WorkerStatusActive",
1: "WorkerStatusInActive",
}
var WorkerStatus_value = map[string]int32{
"WorkerStatusActive": 0,
"WorkerStatusInActive": 1,
}
func (x WorkerStatus) String() string {
return proto.EnumName(WorkerStatus_name, int32(x))
}
func (WorkerStatus) EnumDescriptor() ([]byte, []int) {
return fileDescriptor_91b466c680c1fa25, []int{2}
}
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"`
TaskCmd string `protobuf:"bytes,3,opt,name=task_cmd,json=taskCmd,proto3" json:"task_cmd,omitempty"` TaskCmd string `protobuf:"bytes,3,opt,name=task_cmd,json=taskCmd,proto3" json:"task_cmd,omitempty"`
TaskParam []byte `protobuf:"bytes,4,opt,name=task_param,json=taskParam,proto3" json:"task_param,omitempty"` TaskParam []byte `protobuf:"bytes,4,opt,name=task_param,json=taskParam,proto3" json:"task_param,omitempty"`
TaskTimestamp uint64 `protobuf:"varint,5,opt,name=task_timestamp,json=taskTimestamp,proto3" json:"task_timestamp,omitempty"` TaskTimestamp uint64 `protobuf:"varint,5,opt,name=task_timestamp,json=taskTimestamp,proto3" json:"task_timestamp,omitempty"`
TaskCallback string `protobuf:"bytes,6,opt,name=task_callback,json=taskCallback,proto3" json:"task_callback,omitempty"` TaskCallback string `protobuf:"bytes,6,opt,name=task_callback,json=taskCallback,proto3" json:"task_callback,omitempty"`
TaskUid string `protobuf:"bytes,7,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"` TaskUid string `protobuf:"bytes,7,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"`
TaskFee string `protobuf:"bytes,8,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"` TaskFee string `protobuf:"bytes,8,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"`
// todo: add workload and container publickey
TaskWorkload int64 `protobuf:"varint,9,opt,name=task_workload,json=taskWorkload,proto3" json:"task_workload,omitempty"`
ContainerPubkey []byte `protobuf:"bytes,10,opt,name=container_pubkey,json=containerPubkey,proto3" json:"container_pubkey,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:"-"`
...@@ -197,6 +175,20 @@ func (m *TaskContent) GetTaskFee() string { ...@@ -197,6 +175,20 @@ func (m *TaskContent) GetTaskFee() string {
return "" return ""
} }
func (m *TaskContent) GetTaskWorkload() int64 {
if m != nil {
return m.TaskWorkload
}
return 0
}
func (m *TaskContent) GetContainerPubkey() []byte {
if m != nil {
return m.ContainerPubkey
}
return nil
}
func (*TaskContent) XXX_MessageName() string { func (*TaskContent) XXX_MessageName() string {
return "base.v1.TaskContent" return "base.v1.TaskContent"
} }
...@@ -206,6 +198,8 @@ type TaskResponse struct { ...@@ -206,6 +198,8 @@ type TaskResponse struct {
TaskResult []byte `protobuf:"bytes,2,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"` TaskResult []byte `protobuf:"bytes,2,opt,name=task_result,json=taskResult,proto3" json:"task_result,omitempty"`
TaskUid string `protobuf:"bytes,3,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"` TaskUid string `protobuf:"bytes,3,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"`
TaskFee string `protobuf:"bytes,4,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"` TaskFee string `protobuf:"bytes,4,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"`
TaskIsSucceed bool `protobuf:"varint,5,opt,name=task_is_succeed,json=taskIsSucceed,proto3" json:"task_is_succeed,omitempty"`
TaskError string `protobuf:"bytes,6,opt,name=task_error,json=taskError,proto3" json:"task_error,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:"-"`
...@@ -263,13 +257,26 @@ func (m *TaskResponse) GetTaskFee() string { ...@@ -263,13 +257,26 @@ func (m *TaskResponse) GetTaskFee() string {
return "" return ""
} }
func (m *TaskResponse) GetTaskIsSucceed() bool {
if m != nil {
return m.TaskIsSucceed
}
return false
}
func (m *TaskResponse) GetTaskError() string {
if m != nil {
return m.TaskError
}
return ""
}
func (*TaskResponse) XXX_MessageName() string { func (*TaskResponse) XXX_MessageName() string {
return "base.v1.TaskResponse" return "base.v1.TaskResponse"
} }
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.RegisterEnum("base.v1.WorkerStatus", WorkerStatus_name, WorkerStatus_value)
proto.RegisterType((*TaskContent)(nil), "base.v1.TaskContent") proto.RegisterType((*TaskContent)(nil), "base.v1.TaskContent")
proto.RegisterType((*TaskResponse)(nil), "base.v1.TaskResponse") proto.RegisterType((*TaskResponse)(nil), "base.v1.TaskResponse")
} }
...@@ -277,39 +284,42 @@ func init() { ...@@ -277,39 +284,42 @@ func init() {
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{
// 541 bytes of a gzipped FileDescriptorProto // 581 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x92, 0xcf, 0x6e, 0xd3, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x74, 0x93, 0x51, 0x6f, 0xd3, 0x30,
0x10, 0xc6, 0x6b, 0x27, 0x24, 0xe9, 0xe4, 0x4f, 0x93, 0x05, 0x8a, 0xa9, 0x04, 0x8d, 0x8a, 0x90, 0x10, 0xc7, 0xe7, 0x74, 0xac, 0x9d, 0xdb, 0xae, 0x9d, 0x11, 0x10, 0x26, 0xc1, 0xaa, 0x21, 0x50,
0xa2, 0x48, 0xd8, 0x32, 0xdc, 0xda, 0x0b, 0x75, 0x50, 0x51, 0x91, 0x2a, 0x22, 0xb7, 0x84, 0x0a, 0x99, 0x44, 0xa2, 0xc0, 0xdb, 0xf6, 0x44, 0x0a, 0x43, 0x43, 0x9a, 0xa8, 0xb2, 0x51, 0x26, 0x34,
0x55, 0xaa, 0x36, 0xf6, 0xd4, 0xb5, 0x62, 0x7b, 0x2d, 0xef, 0x3a, 0x52, 0x2e, 0x3c, 0x04, 0x4f, 0xa9, 0x72, 0x92, 0x5b, 0x16, 0x35, 0x89, 0x23, 0xdb, 0x29, 0xca, 0xb7, 0x41, 0x3c, 0xf2, 0x3d,
0x80, 0x38, 0xf2, 0x24, 0x88, 0xc7, 0x80, 0x1b, 0x4f, 0x81, 0x76, 0xed, 0xb8, 0xed, 0xa1, 0x27, 0x90, 0x10, 0x1f, 0x63, 0xbc, 0xf1, 0x29, 0x90, 0x9d, 0x34, 0xd3, 0x1e, 0xf6, 0xd4, 0xeb, 0xef,
0xcf, 0xfe, 0x66, 0xfc, 0x7d, 0xbb, 0xa3, 0x0f, 0xb6, 0xe7, 0x94, 0xa3, 0xb5, 0xb4, 0x2d, 0xe6, 0x9c, 0xff, 0xf9, 0xfe, 0xe7, 0xc3, 0x0f, 0x7d, 0x2a, 0xc0, 0x5e, 0x3a, 0x36, 0x0b, 0x4b, 0x21,
0xaf, 0x38, 0xc7, 0x9c, 0x9b, 0x69, 0xc6, 0x04, 0x23, 0x4d, 0xc9, 0xcd, 0xa5, 0xbd, 0xb3, 0x1b, 0xa0, 0x10, 0x56, 0xce, 0x99, 0x64, 0xa4, 0xad, 0xb8, 0xb5, 0x74, 0x76, 0x76, 0x23, 0xc6, 0xa2,
0x30, 0x16, 0x44, 0x68, 0x29, 0x3c, 0xcf, 0xaf, 0x2c, 0x11, 0xc6, 0xc8, 0x05, 0x8d, 0xd3, 0x62, 0x04, 0x6c, 0x8d, 0xfd, 0xe2, 0xd2, 0x96, 0x71, 0x0a, 0x42, 0xd2, 0x34, 0xaf, 0x4e, 0xee, 0x34,
0x72, 0xa7, 0x52, 0xc8, 0x90, 0xb3, 0x3c, 0xf3, 0xb0, 0xe4, 0x5b, 0x8a, 0x07, 0x2c, 0x60, 0x05, 0x0a, 0x1c, 0x04, 0x2b, 0x78, 0x00, 0x35, 0x1f, 0x68, 0x1e, 0xb1, 0x88, 0x55, 0x60, 0xef, 0xda,
0xd8, 0xfb, 0xa6, 0x43, 0xfb, 0x8c, 0xf2, 0xc5, 0x84, 0x25, 0x02, 0x13, 0x41, 0x9e, 0x40, 0x53, 0xc0, 0xdd, 0x33, 0x2a, 0x16, 0x13, 0x96, 0x49, 0xc8, 0x24, 0x79, 0x84, 0xdb, 0x92, 0x8a, 0xc5,
0x50, 0xbe, 0xb8, 0x0c, 0x7d, 0x43, 0x1b, 0x6a, 0xa3, 0x4d, 0xb7, 0x21, 0x8f, 0xc7, 0x3e, 0x31, 0x3c, 0x0e, 0x4d, 0x34, 0x42, 0xe3, 0x4d, 0x6f, 0x43, 0xfd, 0x3d, 0x0e, 0x89, 0x85, 0x37, 0x75,
0x61, 0x53, 0x35, 0xc4, 0x2a, 0x45, 0x43, 0x1f, 0x6a, 0xa3, 0xde, 0xeb, 0x81, 0x59, 0xde, 0xc7, 0x42, 0x96, 0x39, 0x98, 0xc6, 0x08, 0x8d, 0xb7, 0x5e, 0x6f, 0x5b, 0xf5, 0x7d, 0x2c, 0xa5, 0x70,
0x94, 0x0a, 0x67, 0xab, 0x14, 0xdd, 0x96, 0x28, 0x2b, 0xf2, 0x14, 0x54, 0x7d, 0xe9, 0xc5, 0xbe, 0x56, 0xe6, 0xe0, 0x75, 0x64, 0x1d, 0x91, 0xc7, 0x58, 0xc7, 0xf3, 0x20, 0x0d, 0xcd, 0x96, 0x56,
0x51, 0x53, 0x4a, 0x4a, 0x78, 0x12, 0xfb, 0xe4, 0x19, 0x80, 0x6a, 0xa5, 0x34, 0xa3, 0xb1, 0x51, 0xd2, 0xc2, 0x93, 0x34, 0x24, 0x4f, 0x30, 0xd6, 0xa9, 0x9c, 0x72, 0x9a, 0x9a, 0xeb, 0x23, 0x34,
0x1f, 0x6a, 0xa3, 0x8e, 0xab, 0xc4, 0xa7, 0x12, 0x90, 0x97, 0xd0, 0x2b, 0x9c, 0xd6, 0x6f, 0x32, 0xee, 0x79, 0x5a, 0x7c, 0xaa, 0x00, 0x79, 0x8e, 0xb7, 0xaa, 0x4a, 0xab, 0x9e, 0xcc, 0x7b, 0x23,
0x1e, 0x0c, 0xb5, 0x51, 0xdd, 0xed, 0x2a, 0xed, 0x35, 0x24, 0x2f, 0xa0, 0x5b, 0x18, 0xd0, 0x28, 0x34, 0x5e, 0xf7, 0xfa, 0x5a, 0x7b, 0x05, 0xc9, 0x33, 0xdc, 0xaf, 0x0a, 0xd0, 0x24, 0xf1, 0x69,
0x9a, 0x53, 0x6f, 0x61, 0x34, 0x94, 0x4b, 0x47, 0xb9, 0x94, 0xac, 0xba, 0x45, 0x1e, 0xfa, 0x46, 0xb0, 0x30, 0x37, 0x74, 0x95, 0x9e, 0xae, 0x52, 0xb3, 0xe6, 0x16, 0x45, 0x1c, 0x9a, 0xed, 0x9b,
0xf3, 0xe6, 0x16, 0x9f, 0x42, 0xbf, 0x6a, 0x5d, 0x21, 0x1a, 0xad, 0x9b, 0xd6, 0x11, 0xe2, 0xde, 0x5b, 0x7c, 0x8e, 0xc3, 0x26, 0x75, 0x09, 0x60, 0x76, 0x6e, 0x52, 0x47, 0x00, 0x8d, 0xf4, 0x37,
0x57, 0xe8, 0xc8, 0x17, 0xb9, 0xc8, 0x53, 0x96, 0x70, 0xbc, 0x7f, 0x29, 0xbb, 0xd0, 0x56, 0x8d, 0xc6, 0x17, 0x09, 0xa3, 0xa1, 0xb9, 0x39, 0x42, 0xe3, 0x56, 0x25, 0xfd, 0xa5, 0x66, 0xe4, 0x25,
0x0c, 0x79, 0x1e, 0x09, 0xb5, 0x96, 0x8e, 0xab, 0x1e, 0xe7, 0x2a, 0x72, 0xc7, 0xbf, 0x76, 0xbf, 0x1e, 0x06, 0x2c, 0x93, 0x34, 0xce, 0x80, 0xcf, 0xf3, 0xc2, 0x5f, 0x40, 0x69, 0x62, 0xdd, 0xcb,
0x7f, 0xfd, 0x8e, 0xff, 0xf8, 0x00, 0x5a, 0xeb, 0x8d, 0x92, 0x1e, 0xc0, 0xe9, 0x8a, 0x0b, 0x8c, 0xa0, 0xe1, 0x53, 0x8d, 0xf7, 0x7e, 0x21, 0xdc, 0x53, 0x16, 0x79, 0x20, 0x72, 0x96, 0x09, 0xb8,
0x25, 0xe9, 0x6f, 0x90, 0x2d, 0x68, 0x4f, 0x58, 0x9c, 0xe6, 0x02, 0x15, 0xd0, 0xe4, 0xc0, 0x24, 0xdb, 0xe5, 0x5d, 0xdc, 0xd5, 0x09, 0x0e, 0xa2, 0x48, 0xa4, 0xf6, 0xb9, 0xe7, 0x69, 0xb7, 0x3c,
0xe7, 0x82, 0x15, 0x03, 0xfa, 0xf8, 0x03, 0x74, 0x9d, 0x30, 0x8a, 0xc2, 0x24, 0x38, 0x41, 0x71, 0x4d, 0x6e, 0x35, 0xd4, 0xba, 0xbb, 0xa1, 0xf5, 0xdb, 0x0d, 0xbd, 0xc0, 0x83, 0xaa, 0x9e, 0x98,
0xcd, 0x7c, 0xf9, 0x47, 0x09, 0x8e, 0x32, 0xc4, 0xfe, 0x06, 0x19, 0x54, 0x13, 0xce, 0x4a, 0xee, 0x8b, 0x22, 0x08, 0x00, 0x42, 0xed, 0x69, 0xa7, 0xf2, 0xf4, 0x58, 0x9c, 0x56, 0xb0, 0x99, 0x0c,
0xb3, 0xaf, 0x91, 0xc7, 0x30, 0xa8, 0xd0, 0xbb, 0x3c, 0xa3, 0x22, 0x64, 0x49, 0x5f, 0x1f, 0xbf, 0x70, 0xce, 0x78, 0x6d, 0xa8, 0x9e, 0xcc, 0x7b, 0x05, 0xf6, 0x0f, 0x71, 0x67, 0x35, 0x69, 0xb2,
0x85, 0xce, 0x67, 0x96, 0x2d, 0x30, 0x3b, 0x15, 0x54, 0xe4, 0x9c, 0x6c, 0x03, 0xb9, 0x7d, 0x3e, 0x85, 0xf1, 0x69, 0x29, 0x24, 0xa4, 0x8a, 0x0c, 0xd7, 0xc8, 0x00, 0x77, 0x27, 0x2c, 0xcd, 0x0b,
0xf4, 0x44, 0xb8, 0x94, 0x8a, 0x06, 0x3c, 0xba, 0xcd, 0x8f, 0x93, 0xb2, 0xa3, 0x39, 0xdf, 0xb5, 0x09, 0x1a, 0x20, 0x75, 0x60, 0x52, 0x08, 0xc9, 0xaa, 0x03, 0xc6, 0xfe, 0x47, 0xdc, 0x77, 0xe3,
0x5f, 0x7f, 0x9f, 0x6b, 0xd0, 0xf6, 0x58, 0xbc, 0x4e, 0x8b, 0xd3, 0xfd, 0x58, 0xc6, 0x7a, 0x2a, 0x24, 0x89, 0xb3, 0xe8, 0x04, 0xe4, 0x15, 0x0b, 0xd5, 0x17, 0x35, 0x38, 0xe2, 0x00, 0xc3, 0x35,
0x23, 0x38, 0xd5, 0xbe, 0x1c, 0x06, 0xa1, 0xb8, 0xce, 0xe7, 0xa6, 0xc7, 0xe2, 0x2a, 0xf2, 0x55, 0xb2, 0xdd, 0x9c, 0x70, 0x4b, 0x35, 0xe7, 0x21, 0x22, 0x0f, 0xf0, 0x76, 0x83, 0xde, 0x15, 0x9c,
0xf1, 0x4a, 0x05, 0xd5, 0x63, 0x91, 0x15, 0x60, 0x52, 0x24, 0xde, 0x0a, 0x98, 0x55, 0x06, 0xfc, 0xca, 0x98, 0x65, 0x43, 0xc3, 0xfd, 0x8e, 0x7e, 0xff, 0x7d, 0x8a, 0x70, 0x37, 0x60, 0xe9, 0xea,
0x40, 0x7e, 0x97, 0xf6, 0x0f, 0xbd, 0xe6, 0x9c, 0x9f, 0xff, 0xd4, 0x9b, 0x8e, 0xf4, 0x98, 0xd9, 0x0d, 0xba, 0xfd, 0x4f, 0xf5, 0xb2, 0x4c, 0xd5, 0xc3, 0x9e, 0xa2, 0xaf, 0x6f, 0xa3, 0x58, 0x5e,
0xbf, 0x8b, 0xea, 0x62, 0x66, 0xff, 0xd1, 0x1f, 0x96, 0xd5, 0xc5, 0xfb, 0xa9, 0x73, 0x82, 0x82, 0x15, 0xbe, 0x15, 0xb0, 0xb4, 0x59, 0xa4, 0x26, 0x78, 0xa5, 0x9f, 0x7f, 0xc0, 0x12, 0x3b, 0x82,
0xfa, 0x54, 0xd0, 0x7f, 0x7a, 0x4b, 0xd2, 0xfd, 0xfd, 0x99, 0x3d, 0x6f, 0x28, 0xcd, 0x37, 0xff, 0xac, 0xda, 0x23, 0x3b, 0x62, 0x76, 0xbd, 0x36, 0x87, 0xea, 0x77, 0xe9, 0xfc, 0x30, 0x5a, 0xee,
0x03, 0x00, 0x00, 0xff, 0xff, 0x83, 0xc5, 0x90, 0x40, 0x76, 0x03, 0x00, 0x00, 0xf9, 0xf9, 0x4f, 0xa3, 0xed, 0xaa, 0x1a, 0x33, 0xe7, 0x4f, 0x15, 0x5d, 0xcc, 0x9c, 0x6b, 0xe3,
0x7e, 0x1d, 0x5d, 0x7c, 0x98, 0xba, 0x27, 0x20, 0x69, 0x48, 0x25, 0xfd, 0x67, 0x74, 0x14, 0x3d,
0x38, 0x98, 0x39, 0xfe, 0x86, 0xd6, 0x7c, 0xf3, 0x3f, 0x00, 0x00, 0xff, 0xff, 0xdb, 0x99, 0x4f,
0xa5, 0xcc, 0x03, 0x00, 0x00,
} }
...@@ -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
......
// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: witness/v1/resource.proto
package witnessv1
import (
fmt "fmt"
proto "github.com/gogo/protobuf/proto"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package
type ValidatedProof struct {
Miner string `protobuf:"bytes,1,opt,name=miner,proto3" json:"miner,omitempty"`
Balance uint64 `protobuf:"varint,2,opt,name=balance,proto3" json:"balance,omitempty"`
Workload uint64 `protobuf:"varint,3,opt,name=workload,proto3" json:"workload,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ValidatedProof) Reset() { *m = ValidatedProof{} }
func (m *ValidatedProof) String() string { return proto.CompactTextString(m) }
func (*ValidatedProof) ProtoMessage() {}
func (*ValidatedProof) Descriptor() ([]byte, []int) {
return fileDescriptor_8558ebcb7c19658f, []int{0}
}
func (m *ValidatedProof) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ValidatedProof.Unmarshal(m, b)
}
func (m *ValidatedProof) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ValidatedProof.Marshal(b, m, deterministic)
}
func (m *ValidatedProof) XXX_Merge(src proto.Message) {
xxx_messageInfo_ValidatedProof.Merge(m, src)
}
func (m *ValidatedProof) XXX_Size() int {
return xxx_messageInfo_ValidatedProof.Size(m)
}
func (m *ValidatedProof) XXX_DiscardUnknown() {
xxx_messageInfo_ValidatedProof.DiscardUnknown(m)
}
var xxx_messageInfo_ValidatedProof proto.InternalMessageInfo
func (m *ValidatedProof) GetMiner() string {
if m != nil {
return m.Miner
}
return ""
}
func (m *ValidatedProof) GetBalance() uint64 {
if m != nil {
return m.Balance
}
return 0
}
func (m *ValidatedProof) GetWorkload() uint64 {
if m != nil {
return m.Workload
}
return 0
}
func init() {
proto.RegisterType((*ValidatedProof)(nil), "witness.v1.ValidatedProof")
}
func init() { proto.RegisterFile("witness/v1/resource.proto", fileDescriptor_8558ebcb7c19658f) }
var fileDescriptor_8558ebcb7c19658f = []byte{
// 251 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x2c, 0xcf, 0x2c, 0xc9,
0x4b, 0x2d, 0x2e, 0xd6, 0x2f, 0x33, 0xd4, 0x2f, 0x4a, 0x2d, 0xce, 0x2f, 0x2d, 0x4a, 0x4e, 0xd5,
0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0xe2, 0x82, 0x4a, 0xe9, 0x95, 0x19, 0x2a, 0xc5, 0x70, 0xf1,
0x85, 0x25, 0xe6, 0x64, 0xa6, 0x24, 0x96, 0xa4, 0xa6, 0x04, 0x14, 0xe5, 0xe7, 0xa7, 0x09, 0x89,
0x70, 0xb1, 0xe6, 0x66, 0xe6, 0xa5, 0x16, 0x49, 0x30, 0x2a, 0x30, 0x6a, 0x70, 0x06, 0x41, 0x38,
0x42, 0x12, 0x5c, 0xec, 0x49, 0x89, 0x39, 0x89, 0x79, 0xc9, 0xa9, 0x12, 0x4c, 0x0a, 0x8c, 0x1a,
0x2c, 0x41, 0x30, 0xae, 0x90, 0x14, 0x17, 0x47, 0x79, 0x7e, 0x51, 0x76, 0x4e, 0x7e, 0x62, 0x8a,
0x04, 0x33, 0x58, 0x0a, 0xce, 0x77, 0xda, 0xc8, 0xc8, 0xc5, 0x97, 0x9c, 0x9f, 0xab, 0x87, 0xb0,
0xd0, 0x89, 0x37, 0x08, 0xea, 0x98, 0x00, 0x90, 0x5b, 0x02, 0x18, 0xa3, 0xdc, 0xd3, 0x33, 0x4b,
0x32, 0x4a, 0x93, 0xf4, 0x92, 0xf3, 0x73, 0xf5, 0xf3, 0x53, 0x2a, 0x8b, 0x8b, 0x53, 0x4b, 0x8b,
0xe1, 0x0c, 0x5d, 0xb0, 0x8b, 0x93, 0xf3, 0x73, 0xf4, 0xd3, 0x53, 0xf3, 0xf4, 0xc1, 0x1c, 0xfd,
0xf4, 0x7c, 0x7d, 0x84, 0xdf, 0xac, 0xa1, 0xcc, 0x32, 0xc3, 0x45, 0x4c, 0xcc, 0xe1, 0x11, 0x11,
0xab, 0x98, 0xb8, 0xc2, 0xa1, 0x96, 0x85, 0x19, 0x9e, 0x82, 0x73, 0x62, 0xc2, 0x0c, 0x1f, 0x31,
0x89, 0x21, 0x38, 0x31, 0xee, 0x01, 0x4e, 0xbe, 0xa9, 0x25, 0x89, 0x29, 0x89, 0x25, 0x89, 0xaf,
0x98, 0xb8, 0xa1, 0x12, 0x56, 0x56, 0x61, 0x86, 0x49, 0x6c, 0x60, 0x5b, 0x8c, 0x01, 0x01, 0x00,
0x00, 0xff, 0xff, 0xfc, 0xb2, 0x45, 0x84, 0x41, 0x01, 0x00, 0x00,
}
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