Commit b5d4d6fb authored by vicotor's avatar vicotor

update protocol

parent 80e138e1
...@@ -52,13 +52,13 @@ message TaskContent { ...@@ -52,13 +52,13 @@ message TaskContent {
// ) timestamp (time) PARTITION BY DAY WAL; // ) timestamp (time) PARTITION BY DAY WAL;
message TaskReceipt { message TaskReceipt {
string task_uuid = 1; string task_uuid = 1;
uint64 task_finish_time = 2; uint64 task_timestamp = 2;
uint64 task_id = 3; uint64 task_id = 3;
string task_uid = 4; string task_uid = 4;
int64 task_fee = 5; int64 task_fee = 5;
int64 task_out_len = 6; int64 task_out_len = 6;
int64 task_workload = 7; int64 task_workload = 7;
int64 task_duration = 8; int64 task_duration = 8; // task duration in us.
string task_profit_account = 9; string task_profit_account = 9;
string task_worker_account = 10; string task_worker_account = 10;
string task_result = 11; // some message for task result, ex: failed, success, timeout, etc. string task_result = 11; // some message for task result, ex: failed, success, timeout, etc.
......
...@@ -224,7 +224,7 @@ func (*TaskContent) XXX_MessageName() string { ...@@ -224,7 +224,7 @@ func (*TaskContent) XXX_MessageName() string {
// ) timestamp (time) PARTITION BY DAY WAL; // ) timestamp (time) PARTITION BY DAY WAL;
type TaskReceipt struct { type TaskReceipt struct {
TaskUuid string `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"` TaskUuid string `protobuf:"bytes,1,opt,name=task_uuid,json=taskUuid,proto3" json:"task_uuid,omitempty"`
TaskFinishTime uint64 `protobuf:"varint,2,opt,name=task_finish_time,json=taskFinishTime,proto3" json:"task_finish_time,omitempty"` TaskTimestamp uint64 `protobuf:"varint,2,opt,name=task_timestamp,json=taskTimestamp,proto3" json:"task_timestamp,omitempty"`
TaskId uint64 `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"` TaskId uint64 `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
TaskUid string `protobuf:"bytes,4,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"` TaskUid string `protobuf:"bytes,4,opt,name=task_uid,json=taskUid,proto3" json:"task_uid,omitempty"`
TaskFee int64 `protobuf:"varint,5,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"` TaskFee int64 `protobuf:"varint,5,opt,name=task_fee,json=taskFee,proto3" json:"task_fee,omitempty"`
...@@ -270,9 +270,9 @@ func (m *TaskReceipt) GetTaskUuid() string { ...@@ -270,9 +270,9 @@ func (m *TaskReceipt) GetTaskUuid() string {
return "" return ""
} }
func (m *TaskReceipt) GetTaskFinishTime() uint64 { func (m *TaskReceipt) GetTaskTimestamp() uint64 {
if m != nil { if m != nil {
return m.TaskFinishTime return m.TaskTimestamp
} }
return 0 return 0
} }
...@@ -436,52 +436,51 @@ func init() { ...@@ -436,52 +436,51 @@ 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{
// 743 bytes of a gzipped FileDescriptorProto // 731 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x54, 0xdd, 0x6e, 0xd3, 0x48, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x84, 0x94, 0xdd, 0x4e, 0xdb, 0x48,
0x14, 0xae, 0x9d, 0x34, 0x3f, 0x93, 0xa4, 0x49, 0x5c, 0xed, 0xae, 0xb7, 0xab, 0x6d, 0xa3, 0xae, 0x14, 0xc7, 0xb1, 0x13, 0xf2, 0x31, 0x49, 0x48, 0x62, 0xb4, 0xbb, 0x5e, 0x56, 0x0b, 0x11, 0xab,
0x16, 0x85, 0x4a, 0x24, 0x0a, 0xdc, 0xb5, 0x57, 0x4d, 0xa0, 0xa8, 0xa8, 0x55, 0xa3, 0xf4, 0x57, 0x5d, 0x65, 0x91, 0x36, 0x51, 0xb6, 0x77, 0x70, 0x45, 0xd2, 0x52, 0x51, 0x81, 0x88, 0xc2, 0xa7,
0xa8, 0x52, 0xe4, 0xd8, 0xa7, 0xae, 0x15, 0x7b, 0xc6, 0xf2, 0xcc, 0x14, 0xe5, 0x2d, 0x78, 0x03, 0x2a, 0xa4, 0x68, 0x62, 0x1f, 0x8c, 0x15, 0xdb, 0x63, 0x79, 0x66, 0xa8, 0xf2, 0x10, 0x7d, 0x86,
0x10, 0x97, 0x3c, 0x09, 0xf0, 0x18, 0x70, 0xc7, 0x53, 0xa0, 0x39, 0xe3, 0x38, 0x14, 0x28, 0xbd, 0x56, 0xbd, 0xec, 0x93, 0xb4, 0x7d, 0x8c, 0xf6, 0xae, 0x4f, 0x51, 0xcd, 0x19, 0xc7, 0x29, 0x05,
0xea, 0xf4, 0x3b, 0x5f, 0xce, 0xcf, 0xf7, 0x1d, 0x1f, 0xf2, 0xe7, 0xc4, 0xe1, 0xd0, 0xbd, 0xe9, 0xca, 0x15, 0xc3, 0xef, 0xfc, 0x73, 0xce, 0x9c, 0xf3, 0x1f, 0x1f, 0xf2, 0xeb, 0x84, 0x72, 0xe8,
0x75, 0x99, 0x37, 0xe3, 0x1c, 0x24, 0xef, 0xc4, 0x09, 0x13, 0xcc, 0x2a, 0x2a, 0xbc, 0x73, 0xd3, 0xde, 0xf4, 0xba, 0xcc, 0x9d, 0x71, 0x0e, 0x92, 0x77, 0xe2, 0x84, 0x09, 0x66, 0x15, 0x15, 0xef,
0x5b, 0xdb, 0xf0, 0x19, 0xf3, 0x43, 0xe8, 0x22, 0x3c, 0x91, 0x57, 0x5d, 0x11, 0x44, 0xc0, 0x85, 0xdc, 0xf4, 0xd6, 0x36, 0x3c, 0xc6, 0xbc, 0x00, 0xba, 0x88, 0x27, 0xf2, 0xaa, 0x2b, 0xfc, 0x10,
0x13, 0xc5, 0x9a, 0xb9, 0x96, 0x65, 0x48, 0x80, 0x33, 0x99, 0xb8, 0x90, 0xe2, 0x75, 0xc4, 0x7d, 0xb8, 0xa0, 0x61, 0xac, 0x95, 0x6b, 0x59, 0x86, 0x04, 0x38, 0x93, 0x89, 0x03, 0x29, 0xaf, 0x23,
0xe6, 0x33, 0x0d, 0x6c, 0xbe, 0xc9, 0x91, 0xca, 0x89, 0xc3, 0xa7, 0x03, 0x46, 0x05, 0x50, 0x61, 0xf7, 0x98, 0xc7, 0x34, 0xd8, 0x7c, 0x93, 0x23, 0x95, 0x13, 0xca, 0xa7, 0x03, 0x16, 0x09, 0x88,
0xfd, 0x43, 0xca, 0xc2, 0xe1, 0xd3, 0xb1, 0x94, 0x81, 0x67, 0x1b, 0x2d, 0xa3, 0x5d, 0x1e, 0x95, 0x84, 0xf5, 0x07, 0x29, 0x0b, 0xca, 0xa7, 0x63, 0x29, 0x7d, 0xd7, 0x36, 0x5a, 0x46, 0xbb, 0x3c,
0x14, 0x70, 0x2a, 0x03, 0xcf, 0xea, 0xa4, 0x41, 0x31, 0x8b, 0xc1, 0x36, 0x5b, 0x46, 0x7b, 0xe5, 0x2a, 0x29, 0x70, 0x2a, 0x7d, 0xd7, 0xea, 0xa4, 0x41, 0x31, 0x8b, 0xc1, 0x36, 0x5b, 0x46, 0x7b,
0x71, 0xb3, 0x93, 0xf6, 0xd4, 0x51, 0x59, 0x4e, 0x66, 0x31, 0x68, 0xbe, 0x7a, 0x59, 0x7f, 0x91, 0xe5, 0xff, 0x66, 0x27, 0xbd, 0x53, 0x47, 0x65, 0x39, 0x99, 0xc5, 0xa0, 0xf5, 0xea, 0x64, 0xfd,
0x22, 0xf2, 0x03, 0xcf, 0xce, 0xb5, 0x8c, 0x76, 0x7e, 0x54, 0x50, 0xff, 0xee, 0x7b, 0xd6, 0xdf, 0x46, 0x8a, 0xa8, 0xf7, 0x5d, 0x3b, 0xd7, 0x32, 0xda, 0xf9, 0x51, 0x41, 0xfd, 0xbb, 0xef, 0x5a,
0x04, 0x49, 0x63, 0x37, 0xf2, 0xec, 0x3c, 0x16, 0x41, 0xe2, 0x20, 0xf2, 0xac, 0x7f, 0x09, 0xc1, 0xbf, 0x13, 0x14, 0x8d, 0x9d, 0xd0, 0xb5, 0xf3, 0x58, 0x04, 0x85, 0x83, 0xd0, 0xb5, 0xfe, 0x24,
0x50, 0xec, 0x24, 0x4e, 0x64, 0x2f, 0xb7, 0x8c, 0x76, 0x75, 0x84, 0x55, 0x87, 0x0a, 0xb0, 0xfe, 0x04, 0x43, 0x31, 0x4d, 0x68, 0x68, 0x2f, 0xb7, 0x8c, 0x76, 0x75, 0x84, 0x55, 0x87, 0x0a, 0x58,
0x27, 0x2b, 0xba, 0x85, 0xf9, 0xc0, 0x76, 0x01, 0x33, 0xd7, 0xb0, 0xe8, 0x1c, 0xb4, 0xfe, 0x23, 0x7f, 0x93, 0x15, 0x7d, 0x85, 0x79, 0xc3, 0x76, 0x01, 0x33, 0xd7, 0xb0, 0xe8, 0x1c, 0x5a, 0x7f,
0x35, 0x5d, 0xc0, 0x09, 0xc3, 0x89, 0xe3, 0x4e, 0xed, 0x22, 0x56, 0xa9, 0x62, 0x95, 0x14, 0xcb, 0x91, 0x9a, 0x2e, 0x40, 0x83, 0x60, 0x42, 0x9d, 0xa9, 0x5d, 0xc4, 0x2a, 0x55, 0xac, 0x92, 0xb2,
0xba, 0x50, 0xa3, 0x96, 0x16, 0x5d, 0x9c, 0x06, 0x8b, 0x06, 0xaf, 0x00, 0xec, 0xf2, 0x22, 0xb4, 0xec, 0x16, 0xaa, 0xd5, 0xd2, 0xe2, 0x16, 0xa7, 0xfe, 0xe2, 0x82, 0x57, 0x00, 0x76, 0x79, 0x11,
0x07, 0x90, 0xa5, 0x7e, 0xc5, 0x92, 0x69, 0xc8, 0x1c, 0xcf, 0x26, 0x2d, 0xa3, 0x9d, 0xd3, 0xa9, 0xda, 0x03, 0xc8, 0x52, 0xbf, 0x62, 0xc9, 0x34, 0x60, 0xd4, 0xb5, 0x49, 0xcb, 0x68, 0xe7, 0x74,
0xcf, 0x53, 0xcc, 0x7a, 0x48, 0x1a, 0x2e, 0xa3, 0xc2, 0x09, 0x28, 0x24, 0xe3, 0x58, 0x4e, 0xa6, 0xea, 0xf3, 0x94, 0x59, 0xff, 0x92, 0x86, 0xc3, 0x22, 0x41, 0xfd, 0x08, 0x92, 0x71, 0x2c, 0x27,
0x30, 0xb3, 0x2b, 0x38, 0x4b, 0x3d, 0xc3, 0x87, 0x08, 0x5b, 0xeb, 0xa4, 0xa2, 0x45, 0xa2, 0xe3, 0x53, 0x98, 0xd9, 0x15, 0xec, 0xa5, 0x9e, 0xf1, 0x21, 0x62, 0x6b, 0x9d, 0x54, 0xf4, 0x90, 0xa2,
0x10, 0xa8, 0x5d, 0x6d, 0x19, 0xed, 0x65, 0x3d, 0xf1, 0x3e, 0x3d, 0x00, 0xba, 0xf9, 0x3a, 0x75, 0x71, 0x00, 0x91, 0x5d, 0x6d, 0x19, 0xed, 0x65, 0xdd, 0xf1, 0x7e, 0x74, 0x00, 0xd1, 0xe6, 0xeb,
0x68, 0x04, 0x2e, 0x04, 0xf1, 0x3d, 0x0e, 0xb5, 0x49, 0x43, 0xf7, 0x1d, 0xd0, 0x80, 0x5f, 0xa3, 0xd4, 0xa1, 0x11, 0x38, 0xe0, 0xc7, 0x8f, 0x38, 0x74, 0x77, 0x3c, 0xe6, 0x7d, 0xe3, 0x79, 0xd4,
0x4a, 0x68, 0x54, 0x7e, 0x84, 0xb2, 0xed, 0x21, 0xac, 0x64, 0xba, 0xdf, 0x1b, 0x95, 0x3e, 0x7f, 0x18, 0x95, 0x3b, 0xff, 0xf0, 0x48, 0x96, 0xb1, 0xe5, 0x6c, 0x24, 0x2d, 0x82, 0xdd, 0x8f, 0x99,
0xb7, 0x2a, 0xcb, 0x38, 0x75, 0xa6, 0x4a, 0x8b, 0xa0, 0x00, 0x63, 0x26, 0x05, 0x8e, 0x51, 0xc0, 0x14, 0xd8, 0x43, 0x01, 0xc3, 0xe8, 0xe3, 0x91, 0x14, 0x07, 0x10, 0xdd, 0x1d, 0x5a, 0xf1, 0x9e,
0x30, 0x5a, 0x79, 0x24, 0xc5, 0x01, 0xd0, 0x9f, 0x75, 0x2b, 0xfe, 0x42, 0xb7, 0x39, 0xc9, 0x93, 0xa1, 0xcd, 0x45, 0xae, 0x4c, 0xa8, 0xf0, 0x59, 0x84, 0xa6, 0xa4, 0xa2, 0xa7, 0x29, 0xb3, 0x3a,
0x89, 0x23, 0x02, 0x46, 0xd1, 0x97, 0x94, 0xf4, 0x34, 0xc5, 0xac, 0x0e, 0x59, 0xd5, 0x2b, 0x92, 0x64, 0x55, 0xbf, 0x8f, 0x84, 0x5d, 0xf9, 0x62, 0x4c, 0x1d, 0x87, 0xc9, 0x48, 0xa4, 0x26, 0x35,
0xb0, 0xab, 0x40, 0x8c, 0x1d, 0xd7, 0x65, 0x92, 0x8a, 0xd4, 0xa7, 0x26, 0xee, 0x0a, 0x46, 0x76, 0xf1, 0xa1, 0x60, 0x64, 0x57, 0x07, 0x32, 0xbd, 0xaa, 0x0c, 0x49, 0xa6, 0x27, 0x0b, 0xfd, 0x39,
0x75, 0x20, 0xe3, 0xab, 0xca, 0x90, 0x64, 0x7c, 0xb2, 0xe0, 0x9f, 0x63, 0x64, 0xce, 0xdf, 0x48, 0x46, 0xe6, 0xfa, 0x8d, 0xd4, 0x8e, 0x04, 0xb8, 0x0c, 0x04, 0x9a, 0x56, 0xd6, 0xad, 0x8c, 0x90,
0x1d, 0x49, 0x80, 0xcb, 0x50, 0xa0, 0x6f, 0x65, 0x3d, 0xca, 0x08, 0x91, 0xcd, 0x8f, 0x06, 0xa9, 0x6c, 0x7e, 0x34, 0x48, 0x55, 0xfb, 0xc1, 0x63, 0x16, 0x71, 0xf8, 0xb9, 0x21, 0x3f, 0xa4, 0x33,
0x6a, 0x4b, 0x78, 0xcc, 0x28, 0x87, 0xdf, 0x7b, 0xf2, 0x43, 0x3a, 0x13, 0xd7, 0xe0, 0xbb, 0x74, 0xf1, 0x0d, 0x7c, 0x97, 0xee, 0xd6, 0xc4, 0x73, 0x0f, 0x4f, 0x3c, 0x7f, 0xfb, 0x11, 0xfe, 0x43,
0xb7, 0x14, 0xcf, 0xdd, 0xad, 0x78, 0xfe, 0xf6, 0x1e, 0x3e, 0x20, 0x75, 0x6d, 0x20, 0x1f, 0x73, 0xea, 0xda, 0x40, 0x3e, 0xe6, 0xd2, 0x71, 0x00, 0x5c, 0xf4, 0xa4, 0xa4, 0x8d, 0xde, 0xe7, 0xc7,
0xe9, 0xba, 0x00, 0x1e, 0x7a, 0x52, 0xd2, 0x9f, 0xc2, 0x3e, 0x3f, 0xd6, 0x60, 0xf6, 0x41, 0x41, 0x1a, 0x66, 0x5f, 0x13, 0x24, 0x09, 0x4b, 0xd0, 0x97, 0xb2, 0x7e, 0x5b, 0xcf, 0x14, 0xd8, 0xda,
0x92, 0xb0, 0x04, 0x7d, 0x29, 0xeb, 0xf5, 0x7a, 0xa6, 0x80, 0xad, 0x1d, 0x52, 0x9a, 0x7f, 0xb9, 0x21, 0xa5, 0xf9, 0x67, 0x6b, 0xad, 0x10, 0x72, 0x3c, 0xe3, 0x02, 0x42, 0x45, 0x1a, 0x4b, 0x56,
0xd6, 0x0a, 0x21, 0xc7, 0x33, 0x2e, 0x20, 0x52, 0x48, 0x63, 0xc9, 0xaa, 0x93, 0xca, 0x80, 0x45, 0x9d, 0x54, 0x06, 0x2c, 0x8c, 0xa5, 0x00, 0x04, 0x86, 0x12, 0x0c, 0x24, 0x17, 0x4c, 0x0b, 0xcc,
0xb1, 0x14, 0x80, 0x80, 0xa1, 0x08, 0x03, 0xc9, 0x05, 0xd3, 0x04, 0x73, 0xeb, 0x05, 0xa9, 0xf5, 0xad, 0x17, 0xa4, 0xd6, 0xf7, 0x83, 0xc0, 0x8f, 0xbc, 0x43, 0x10, 0xd7, 0xcc, 0x55, 0xbf, 0x48,
0x83, 0x30, 0x0c, 0xa8, 0x7f, 0x08, 0xe2, 0x9a, 0x79, 0xea, 0x17, 0x29, 0xb0, 0x97, 0x00, 0x34, 0xc1, 0x5e, 0x02, 0xd0, 0x58, 0xb2, 0x9a, 0x99, 0xa2, 0x3f, 0x53, 0x8f, 0xaf, 0x61, 0x58, 0xbf,
0x96, 0xac, 0x66, 0xc6, 0xe8, 0xcf, 0xd4, 0xde, 0x35, 0x0c, 0xeb, 0x0f, 0xd2, 0xcc, 0xa0, 0xb9, 0x90, 0x66, 0x86, 0xe6, 0x9e, 0x36, 0xcc, 0xfe, 0x5b, 0xe3, 0xc3, 0x97, 0x75, 0x83, 0x54, 0x1c,
0xa7, 0x0d, 0xb3, 0xff, 0xd6, 0xf8, 0xf0, 0x65, 0xdd, 0x20, 0x15, 0x97, 0x45, 0xf3, 0x9b, 0xd2, 0x16, 0xce, 0x17, 0x4a, 0xbf, 0x76, 0x94, 0x6e, 0xbf, 0xa1, 0xda, 0x54, 0x43, 0xe3, 0xe5, 0xae,
0xaf, 0x1d, 0xa5, 0x07, 0x70, 0xa8, 0x8e, 0xd5, 0xd0, 0x78, 0xb9, 0xeb, 0x07, 0xe2, 0x5a, 0x4e, 0xe7, 0x8b, 0x6b, 0x39, 0xe9, 0x38, 0x2c, 0xcc, 0x36, 0x63, 0x76, 0xf8, 0x0f, 0xf7, 0x99, 0xc3,
0x3a, 0x2e, 0x8b, 0xb2, 0xe3, 0x98, 0x3d, 0x1e, 0xe1, 0x49, 0x73, 0x59, 0xd8, 0xf5, 0x81, 0xea, 0x82, 0xae, 0x07, 0x91, 0x5e, 0x8c, 0x5d, 0x8f, 0x75, 0xd3, 0x3d, 0xb8, 0xa3, 0xfe, 0xde, 0xf4,
0xdb, 0xd8, 0xf5, 0x59, 0x37, 0x3d, 0x85, 0x3b, 0xea, 0xef, 0x4d, 0xef, 0x9d, 0x99, 0xeb, 0x5f, 0xde, 0x99, 0xb9, 0xfe, 0xc5, 0xc5, 0x7b, 0xb3, 0xd8, 0x57, 0x35, 0xce, 0x7a, 0x9f, 0xf4, 0xe9,
0x5c, 0xbc, 0x37, 0x8b, 0x7d, 0x55, 0xe3, 0xac, 0xf7, 0x49, 0xbf, 0x2e, 0xcf, 0x7a, 0x9f, 0xcd, 0xf2, 0xac, 0xf7, 0xd9, 0x5c, 0x4d, 0x4f, 0x97, 0xcf, 0x87, 0xfd, 0x43, 0x10, 0xd4, 0xa5, 0x82,
0xd5, 0xf4, 0x75, 0xf9, 0x7c, 0xd8, 0x3f, 0x04, 0xe1, 0x78, 0x8e, 0x70, 0xbe, 0x9a, 0x25, 0x85, 0x7e, 0x35, 0x4b, 0x8a, 0x6e, 0x6f, 0x9f, 0xf5, 0x26, 0x05, 0xcc, 0xf9, 0xe4, 0x5b, 0x00, 0x00,
0x6e, 0x6f, 0x9f, 0xf5, 0x26, 0x05, 0xcc, 0xf9, 0xe4, 0x5b, 0x00, 0x00, 0x00, 0xff, 0xff, 0x88, 0x00, 0xff, 0xff, 0x95, 0xd6, 0xd1, 0x5e, 0x9d, 0x05, 0x00, 0x00,
0x53, 0x54, 0x2f, 0xa0, 0x05, 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