Skip to content

O
OdysseusProtocol
Commit 8f1499cf authored by Your Name's avatar Your Name
Browse files
Options

add input len

parent e47ee4db
Hide whitespace changes
Inline Side-by-side
Showing with 51 additions and 39 deletions
baseapi/base/v1/odysseus.proto
View file @ 8f1499cf
...@@ -34,6 +34,7 @@ message TaskContent { ...@@ -34,6 +34,7 @@ message TaskContent {
// todo: add workload and container publickey // todo: add workload and container publickey
int64 task_workload = 10; int64 task_workload = 10;
bytes container_pubkey = 11; bytes container_pubkey = 11;
int32 task_in_len =12;
} }
message TaskResponse { message TaskResponse {
......
gen/proto/go/base/v1/odysseus.pb.go
View file @ 8f1499cf
...@@ -91,6 +91,7 @@ type TaskContent struct { ...@@ -91,6 +91,7 @@ type TaskContent struct {
// todo: add workload and container publickey // todo: add workload and container publickey
TaskWorkload int64 `protobuf:"varint,10,opt,name=task_workload,json=taskWorkload,proto3" json:"task_workload,omitempty"` TaskWorkload int64 `protobuf:"varint,10,opt,name=task_workload,json=taskWorkload,proto3" json:"task_workload,omitempty"`
ContainerPubkey []byte `protobuf:"bytes,11,opt,name=container_pubkey,json=containerPubkey,proto3" json:"container_pubkey,omitempty"` ContainerPubkey []byte `protobuf:"bytes,11,opt,name=container_pubkey,json=containerPubkey,proto3" json:"container_pubkey,omitempty"`
TaskInLen int32 `protobuf:"varint,12,opt,name=task_in_len,json=taskInLen,proto3" json:"task_in_len,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 +198,13 @@ func (m *TaskContent) GetContainerPubkey() []byte { ...@@ -197,6 +198,13 @@ func (m *TaskContent) GetContainerPubkey() []byte {
return nil return nil
} }
func (m *TaskContent) GetTaskInLen() int32 {
if m != nil {
return m.TaskInLen
}
return 0
}
func (*TaskContent) XXX_MessageName() string { func (*TaskContent) XXX_MessageName() string {
return "base.v1.TaskContent" return "base.v1.TaskContent"
} }
...@@ -292,43 +300,44 @@ func init() { ...@@ -292,43 +300,44 @@ 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{
// 594 bytes of a gzipped FileDescriptorProto // 616 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x93, 0xcd, 0x6e, 0xd3, 0x40, 0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x93, 0xdd, 0x6e, 0xd3, 0x4c,
0x10, 0xc7, 0xbb, 0x4e, 0x69, 0x92, 0x4d, 0xd2, 0xa4, 0x8b, 0x00, 0x53, 0x04, 0x8d, 0x8a, 0x40, 0x10, 0x86, 0xbb, 0x4e, 0xdb, 0x24, 0x9b, 0xa4, 0x49, 0xf7, 0xd3, 0x07, 0xa6, 0x88, 0x36, 0x2a,
0xa1, 0x12, 0xb1, 0x02, 0xb7, 0xf6, 0x84, 0x03, 0x45, 0x45, 0xaa, 0x88, 0xd2, 0x0f, 0x2a, 0x54, 0x02, 0x85, 0x4a, 0xc4, 0x0a, 0x9c, 0xb5, 0x47, 0x38, 0x50, 0x54, 0x44, 0x45, 0x94, 0xfe, 0x50,
0x29, 0xda, 0xd8, 0x53, 0xd7, 0x8a, 0xed, 0xb5, 0xf6, 0xa3, 0xc8, 0x6f, 0x83, 0x38, 0xf2, 0x24, 0xa1, 0x4a, 0xd1, 0xc6, 0x9e, 0xba, 0x56, 0x6c, 0xaf, 0xb5, 0x3f, 0x45, 0xb9, 0x1a, 0x10, 0x87,
0xc0, 0x63, 0xc0, 0x8d, 0x97, 0x00, 0xed, 0xae, 0xe3, 0xaa, 0x07, 0x38, 0x65, 0xf2, 0x9b, 0xbf, 0x5c, 0x09, 0x70, 0x19, 0x70, 0xc6, 0x55, 0xa0, 0xdd, 0x75, 0x1c, 0xf5, 0x00, 0x8e, 0xb2, 0x79,
0xe7, 0x73, 0x07, 0xdf, 0x9d, 0x53, 0x01, 0xde, 0xd5, 0xc8, 0x63, 0x61, 0x21, 0x04, 0x28, 0x31, 0xf6, 0xf5, 0xcc, 0xbc, 0x33, 0x3b, 0xf8, 0xce, 0x94, 0x0a, 0xf0, 0x6e, 0x06, 0x1e, 0x0b, 0xe7,
0xcc, 0x39, 0x93, 0x8c, 0xd4, 0x35, 0x1f, 0x5e, 0x8d, 0x36, 0xb7, 0x22, 0xc6, 0xa2, 0x04, 0x3c, 0x42, 0x80, 0x12, 0xfd, 0x9c, 0x33, 0xc9, 0x48, 0x55, 0xf3, 0xfe, 0xcd, 0x60, 0x6b, 0x27, 0x62,
0x83, 0xe7, 0xea, 0xc2, 0x93, 0x71, 0x0a, 0x42, 0xd2, 0x34, 0xb7, 0xca, 0xcd, 0x2a, 0x02, 0x07, 0x2c, 0x4a, 0xc0, 0x33, 0x78, 0xaa, 0xae, 0x3c, 0x19, 0xa7, 0x20, 0x24, 0x4d, 0x73, 0xab, 0xdc,
0xc1, 0x14, 0x0f, 0xa0, 0xe4, 0x5d, 0xc3, 0x23, 0x16, 0x31, 0x0b, 0xb6, 0xff, 0x38, 0xb8, 0x75, 0x2a, 0x23, 0x70, 0x10, 0x4c, 0xf1, 0x00, 0x0a, 0xde, 0x36, 0x3c, 0x62, 0x11, 0xb3, 0x60, 0xf7,
0x4c, 0xc5, 0x62, 0xcc, 0x32, 0x09, 0x99, 0x24, 0x0f, 0x70, 0x53, 0x52, 0xb1, 0x98, 0x29, 0x15, 0x53, 0x05, 0x37, 0x4e, 0xa9, 0x98, 0x0d, 0x59, 0x26, 0x21, 0x93, 0xe4, 0x3e, 0xae, 0x4b, 0x2a,
0x87, 0x2e, 0xea, 0xa3, 0x41, 0x73, 0xda, 0xd0, 0xe0, 0x44, 0xc5, 0x21, 0x19, 0x96, 0x4e, 0x59, 0x66, 0x13, 0xa5, 0xe2, 0xd0, 0x45, 0x5d, 0xd4, 0xab, 0x8f, 0x6b, 0x1a, 0x9c, 0xa9, 0x38, 0x24,
0xe4, 0xe0, 0x3a, 0x7d, 0x34, 0x58, 0x7f, 0xb1, 0x31, 0x2c, 0x6b, 0x1a, 0xea, 0x28, 0xc7, 0x45, 0xfd, 0xe2, 0x52, 0xce, 0x73, 0x70, 0x9d, 0x2e, 0xea, 0x6d, 0x3c, 0xdb, 0xec, 0x17, 0x35, 0xf5,
0x0e, 0x56, 0xaf, 0x2d, 0x72, 0x0f, 0xd7, 0x8d, 0x3e, 0x0e, 0xdd, 0x5a, 0x1f, 0x0d, 0x56, 0xa7, 0x75, 0x94, 0xd3, 0x79, 0x0e, 0x56, 0xaf, 0x4f, 0xe4, 0x2e, 0xae, 0x1a, 0x7d, 0x1c, 0xba, 0x95,
0x6b, 0xfa, 0xef, 0x41, 0x48, 0xee, 0x63, 0x23, 0x9a, 0x05, 0x69, 0xe8, 0xae, 0x9a, 0x24, 0x46, 0x2e, 0xea, 0xad, 0x8e, 0xd7, 0xf5, 0xdf, 0xa3, 0x90, 0xdc, 0xc3, 0x46, 0x34, 0x09, 0xd2, 0xd0,
0x38, 0x4e, 0x43, 0xf2, 0x10, 0x63, 0xe3, 0xca, 0x29, 0xa7, 0xa9, 0x7b, 0xab, 0x8f, 0x06, 0xed, 0x5d, 0x35, 0x49, 0x8c, 0x70, 0x98, 0x86, 0xe4, 0x01, 0xc6, 0xe6, 0x2a, 0xa7, 0x9c, 0xa6, 0xee,
0xa9, 0xc9, 0x3a, 0xd1, 0x80, 0x3c, 0xc1, 0xeb, 0xb6, 0x84, 0x65, 0xc3, 0xee, 0x9a, 0x89, 0xdc, 0x5a, 0x17, 0xf5, 0x9a, 0x63, 0x93, 0x75, 0xa4, 0x01, 0x79, 0x84, 0x37, 0x6c, 0x09, 0x0b, 0xc3,
0x31, 0x49, 0x97, 0x90, 0x3c, 0xc6, 0x1d, 0x9b, 0x80, 0x26, 0xc9, 0x9c, 0x06, 0x0b, 0xb7, 0x6e, 0xee, 0xba, 0x89, 0xdc, 0x32, 0x49, 0x17, 0x90, 0x3c, 0xc4, 0x2d, 0x9b, 0x80, 0x26, 0xc9, 0x94,
0xb2, 0xb4, 0x4d, 0x96, 0x92, 0x55, 0x55, 0xe8, 0x56, 0x1b, 0xd7, 0x55, 0x9c, 0xc4, 0xd7, 0x05, 0x06, 0x33, 0xb7, 0x6a, 0xb2, 0x34, 0x4d, 0x96, 0x82, 0x95, 0x55, 0x68, 0xab, 0xb5, 0x65, 0x15,
0x5e, 0x00, 0xb8, 0xcd, 0x6b, 0xd7, 0x3e, 0x40, 0x15, 0xfa, 0x13, 0xe3, 0x8b, 0x84, 0xd1, 0xd0, 0x67, 0xf1, 0xb2, 0xc0, 0x2b, 0x00, 0xb7, 0xbe, 0xbc, 0x3a, 0x04, 0x28, 0x43, 0x7f, 0x64, 0x7c,
0xc5, 0x7d, 0x34, 0xa8, 0xd9, 0xd0, 0x1f, 0x4a, 0x46, 0x9e, 0xe1, 0x5e, 0xc0, 0x32, 0x49, 0xe3, 0x96, 0x30, 0x1a, 0xba, 0xb8, 0x8b, 0x7a, 0x15, 0x1b, 0xfa, 0x7d, 0xc1, 0xc8, 0x13, 0xdc, 0x09,
0x0c, 0xf8, 0x2c, 0x57, 0xf3, 0x05, 0x14, 0x6e, 0xcb, 0xf4, 0xd2, 0xad, 0xf8, 0xc4, 0xe0, 0xed, 0x58, 0x26, 0x69, 0x9c, 0x01, 0x9f, 0xe4, 0x6a, 0x3a, 0x83, 0xb9, 0xdb, 0x30, 0x5e, 0xda, 0x25,
0xef, 0x08, 0xb7, 0xf5, 0xec, 0xa6, 0x20, 0x72, 0x96, 0x09, 0xf8, 0xff, 0x0a, 0xb6, 0x70, 0xcb, 0x1f, 0x19, 0x4c, 0xb6, 0x71, 0xc3, 0x36, 0x29, 0x9b, 0x24, 0x90, 0xb9, 0xcd, 0x2e, 0xea, 0xad,
0x38, 0x39, 0x08, 0x95, 0x48, 0xb3, 0x84, 0xf6, 0xd4, 0x4c, 0x6c, 0x6a, 0xc8, 0x8d, 0xa6, 0x6a, 0x59, 0xc7, 0x47, 0xd9, 0x5b, 0xc8, 0x76, 0xbf, 0x23, 0xdc, 0xd4, 0xbd, 0x1d, 0x83, 0xc8, 0x59,
0xff, 0x6e, 0x6a, 0xf5, 0x66, 0x53, 0x4f, 0x71, 0xd7, 0x6e, 0x4a, 0xcc, 0x84, 0x0a, 0x02, 0x80, 0x26, 0xe0, 0xdf, 0x23, 0xda, 0x29, 0xa2, 0x71, 0x10, 0x2a, 0x91, 0x66, 0x48, 0xcd, 0xb1, 0xe9,
0xd0, 0x8c, 0xbe, 0x61, 0xe7, 0x7a, 0x20, 0x8e, 0x2c, 0xac, 0xb6, 0x03, 0x9c, 0x33, 0x6e, 0x46, 0xe8, 0xd8, 0x90, 0x5b, 0xa6, 0x2b, 0x7f, 0x37, 0xbd, 0x7a, 0xdb, 0xf4, 0x63, 0xdc, 0xb6, 0x45,
0xdf, 0xb4, 0xdb, 0x79, 0xa3, 0xc1, 0xce, 0x1e, 0x6e, 0x2c, 0x9f, 0x01, 0x59, 0xc7, 0xf8, 0xa8, 0x8a, 0x89, 0x50, 0x41, 0x00, 0x10, 0x9a, 0xd1, 0xd4, 0x6c, 0xdf, 0x8f, 0xc4, 0x89, 0x85, 0xe5,
0x10, 0x12, 0x52, 0x4d, 0x7a, 0x2b, 0xa4, 0x8b, 0x5b, 0x63, 0x96, 0xe6, 0x4a, 0x82, 0x01, 0x48, 0xf4, 0x80, 0x73, 0xc6, 0xcd, 0x68, 0xea, 0xd6, 0xcb, 0x2b, 0x0d, 0xf6, 0x0e, 0x70, 0x6d, 0xf1,
0x0b, 0xc6, 0x4a, 0x48, 0x66, 0x05, 0xce, 0xce, 0x3b, 0xdc, 0xf1, 0xe3, 0x24, 0x89, 0xb3, 0xe8, 0x4c, 0xc8, 0x06, 0xc6, 0x27, 0x73, 0x21, 0x21, 0xd5, 0xa4, 0xb3, 0x42, 0xda, 0xb8, 0x31, 0x64,
0x10, 0xe4, 0x25, 0x0b, 0xf5, 0x17, 0x25, 0xd8, 0xe7, 0x00, 0xbd, 0x15, 0xb2, 0x51, 0x29, 0xfc, 0x69, 0xae, 0x24, 0x18, 0x80, 0xb4, 0x60, 0xa8, 0x84, 0x64, 0x56, 0xe0, 0xec, 0xbd, 0xc1, 0x2d,
0x42, 0xef, 0xba, 0x87, 0xc8, 0x1d, 0xbc, 0x51, 0xa1, 0xd7, 0x8a, 0x53, 0x19, 0xb3, 0xac, 0xe7, 0x3f, 0x4e, 0x92, 0x38, 0x8b, 0x8e, 0x41, 0x5e, 0xb3, 0x50, 0x7f, 0x51, 0x80, 0x43, 0x0e, 0xd0,
0xf8, 0x9f, 0xd1, 0xb7, 0x5f, 0x8f, 0x10, 0x6e, 0x05, 0x2c, 0x5d, 0x3e, 0x50, 0xbf, 0xf3, 0xbe, 0x59, 0x21, 0x9b, 0xa5, 0xc2, 0x9f, 0xeb, 0xb7, 0xd0, 0x41, 0xe4, 0x7f, 0xbc, 0x59, 0xa2, 0x97,
0xbc, 0xa6, 0x89, 0x7e, 0xf9, 0x13, 0xf4, 0xf1, 0x55, 0x14, 0xcb, 0x4b, 0x35, 0x1f, 0x06, 0x2c, 0x8a, 0x53, 0x19, 0xb3, 0xac, 0xe3, 0xf8, 0x9f, 0xd1, 0xb7, 0x5f, 0xdb, 0x08, 0x37, 0x02, 0x96,
0xad, 0x2e, 0xad, 0x32, 0x9e, 0x9b, 0xfb, 0x08, 0x58, 0xe2, 0x45, 0x90, 0xd9, 0x43, 0xf3, 0x22, 0x2e, 0x1e, 0xb0, 0xdf, 0x7a, 0x57, 0x6c, 0xdb, 0x48, 0x6f, 0xc6, 0x08, 0x7d, 0x78, 0x11, 0xc5,
0xe6, 0x95, 0x77, 0xb5, 0xa7, 0x7f, 0xaf, 0x46, 0x5f, 0x9c, 0x9a, 0x7f, 0x76, 0xf6, 0xd5, 0xa9, 0xf2, 0x5a, 0x4d, 0xfb, 0x01, 0x4b, 0xcb, 0x4d, 0x2c, 0x0f, 0x4f, 0xcd, 0xfe, 0x04, 0x2c, 0xf1,
0xfb, 0x3a, 0xc7, 0xe9, 0xe8, 0x87, 0xb5, 0xce, 0x4f, 0x47, 0x3f, 0x9d, 0xdb, 0xa5, 0x75, 0xfe, 0x22, 0xc8, 0xec, 0x22, 0x7a, 0x11, 0xf3, 0x8a, 0xbd, 0x3b, 0xd0, 0xbf, 0x37, 0x83, 0x2f, 0x4e,
0x76, 0xe2, 0x1f, 0x82, 0xa4, 0x21, 0x95, 0xf4, 0xb7, 0xd3, 0xd0, 0x74, 0x77, 0xf7, 0x74, 0x34, 0xc5, 0xbf, 0xb8, 0xf8, 0xea, 0x54, 0x7d, 0x9d, 0xe3, 0x7c, 0xf0, 0xc3, 0x9e, 0x2e, 0xcf, 0x07,
0x5f, 0x33, 0x31, 0x5f, 0xfe, 0x0d, 0x00, 0x00, 0xff, 0xff, 0x8d, 0xdb, 0x48, 0x1a, 0xed, 0x03, 0x3f, 0x9d, 0xff, 0x8a, 0xd3, 0xe5, 0xeb, 0x91, 0x7f, 0x0c, 0x92, 0x86, 0x54, 0xd2, 0xdf, 0x4e,
0x00, 0x00, 0x4d, 0xd3, 0xfd, 0xfd, 0xf3, 0xc1, 0x74, 0xdd, 0xc4, 0x7c, 0xfe, 0x27, 0x00, 0x00, 0xff, 0xff,
0x9e, 0x6d, 0x1e, 0x43, 0x0d, 0x04, 0x00, 0x00,
} }
gen/proto/go/nodemanager/v1/request_response.pb.go
View file @ 8f1499cf
...@@ -24,6 +24,7 @@ const _ = proto.GoGoProtoPackageIsVersion3 // please upgrade the proto package ...@@ -24,6 +24,7 @@ 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
...@@ -153,6 +154,7 @@ func (*WorkerMessage) XXX_OneofWrappers() []interface{} { ...@@ -153,6 +154,7 @@ 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
......
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