update

Makefile

@@ -2,7 +2,7 @@
 PROTO_GO_FILES = $(shell find . -path -prune -o -type f -name '*.pb.go' -print | grep -v vendor)
 #PROTO_GO_FILES = $(patsubst %.proto, %.pb.go, $(PROTO_FILES))
 DEST=${PWD}
-BIN=protocol
+BIN=odysseus
 
 .PHONY: all build generate deps clean lint
 

baseapi/base/v1/odysseus.proto

@@ -16,9 +16,9 @@ enum TaskType {
 }
 
 enum BillingMethod {
-    BillingFree = 1;
-    BillingByTime = 2;
-    BillingByDuration = 3;
+    BillingFree = 0;
+    BillingByTime = 1;
+    BillingByDuration = 2;
 }
 
 message TaskContent {

buf.gen.yaml

@@ -2,16 +2,15 @@ version: v1
 managed:
   enabled: true
   go_package_prefix:
-    default: github.com/CaduceusMetaverseProtocol/MetaProtocol/gen/proto/go
+    default: github.com/odysseus/odysseus-protocol/gen/proto/go
     except:
       - buf.build/gogo/protobuf
 
-
 plugins:
   - name: gogo
     out: gen/proto/go
     opt:
-      - paths=source_relative 
+      - paths=source_relative
       - Mgoogle/protobuf/any.proto=github.com/gogo/protobuf/types
       - Mgoogle/protobuf/timestamp.proto=github.com/gogo/protobuf/types
       - Mgoogle/protobuf=github.com/gogo/protobuf/types

gen/proto/go/base/v1/options.pb.go

+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: base/v1/options.proto
+
+package basev1
+
+import (
+	fmt "fmt"
+	proto "github.com/gogo/protobuf/proto"
+	descriptorpb "google.golang.org/protobuf/types/descriptorpb"
+	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
+
+var E_BytesSize = &proto.ExtensionDesc{
+	ExtendedType:  (*descriptorpb.FieldOptions)(nil),
+	ExtensionType: (*uint32)(nil),
+	Field:         50000,
+	Name:          "base.v1.bytes_size",
+	Tag:           "varint,50000,opt,name=bytes_size",
+	Filename:      "base/v1/options.proto",
+}
+
+func init() {
+	proto.RegisterExtension(E_BytesSize)
+}
+
+func init() { proto.RegisterFile("base/v1/options.proto", fileDescriptor_35190a910ebf5bf3) }
+
+var fileDescriptor_35190a910ebf5bf3 = []byte{
+	// 246 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x12, 0x4d, 0x4a, 0x2c, 0x4e,
+	0xd5, 0x2f, 0x33, 0xd4, 0xcf, 0x2f, 0x28, 0xc9, 0xcc, 0xcf, 0x2b, 0xd6, 0x2b, 0x28, 0xca, 0x2f,
+	0xc9, 0x17, 0x62, 0x07, 0x09, 0xeb, 0x95, 0x19, 0x4a, 0x29, 0xa4, 0xe7, 0xe7, 0xa7, 0xe7, 0xa4,
+	0xea, 0x83, 0x85, 0x93, 0x4a, 0xd3, 0xf4, 0x53, 0x52, 0x8b, 0x93, 0x8b, 0x32, 0x0b, 0x4a, 0xf2,
+	0x8b, 0x20, 0x4a, 0xad, 0xec, 0xb8, 0xb8, 0x92, 0x2a, 0x4b, 0x52, 0x8b, 0xe3, 0x8b, 0x33, 0xab,
+	0x52, 0x85, 0x64, 0xf5, 0x20, 0x1a, 0xf4, 0x60, 0x1a, 0xf4, 0xdc, 0x32, 0x53, 0x73, 0x52, 0xfc,
+	0x21, 0xa6, 0x4b, 0x5c, 0x68, 0x63, 0x56, 0x60, 0xd4, 0xe0, 0x0d, 0xe2, 0x04, 0x6b, 0x09, 0xce,
+	0xac, 0x4a, 0x75, 0x9a, 0xcd, 0xc8, 0xc5, 0x9d, 0x9c, 0x9f, 0xab, 0x07, 0xb5, 0xd1, 0x89, 0x07,
+	0xaa, 0x36, 0x00, 0x64, 0x40, 0x00, 0x63, 0x94, 0x63, 0x7a, 0x66, 0x49, 0x46, 0x69, 0x92, 0x5e,
+	0x72, 0x7e, 0xae, 0x7e, 0x7e, 0x4a, 0x65, 0x71, 0x71, 0x6a, 0x69, 0x31, 0x9c, 0xa1, 0x0b, 0xb6,
+	0x26, 0x39, 0x3f, 0x47, 0x3f, 0x3d, 0x35, 0x0f, 0xe2, 0x48, 0xfd, 0xf4, 0x7c, 0x7d, 0xa8, 0xa7,
+	0xac, 0x41, 0x74, 0x99, 0xe1, 0x22, 0x26, 0x66, 0xa7, 0x88, 0x88, 0x55, 0x4c, 0xec, 0x4e, 0x20,
+	0x2b, 0xc2, 0x0c, 0x4f, 0x41, 0x58, 0x31, 0x61, 0x86, 0x8f, 0x98, 0x84, 0xa1, 0xac, 0x18, 0xf7,
+	0x00, 0x27, 0xdf, 0xd4, 0x92, 0xc4, 0x94, 0xc4, 0x92, 0xc4, 0x57, 0x4c, 0x1c, 0x20, 0x51, 0x2b,
+	0xab, 0x30, 0xc3, 0x24, 0x36, 0xb0, 0x99, 0xc6, 0x80, 0x00, 0x00, 0x00, 0xff, 0xff, 0x3a, 0x39,
+	0xbb, 0xa7, 0x28, 0x01, 0x00, 0x00,
+}

gen/proto/go/base/v1/resource.pb.go

+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: base/v1/resource.proto
+
+package basev1
+
+import (
+	fmt "fmt"
+	proto "github.com/gogo/protobuf/proto"
+	_ "github.com/gogo/protobuf/types"
+	_ "github.com/odysseus/odysseus-protocol/gen/proto/go/base"
+	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 Bytes32 struct {
+	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *Bytes32) Reset()         { *m = Bytes32{} }
+func (m *Bytes32) String() string { return proto.CompactTextString(m) }
+func (*Bytes32) ProtoMessage()    {}
+func (*Bytes32) Descriptor() ([]byte, []int) {
+	return fileDescriptor_fc4a30c7a1e70305, []int{0}
+}
+func (m *Bytes32) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_Bytes32.Unmarshal(m, b)
+}
+func (m *Bytes32) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_Bytes32.Marshal(b, m, deterministic)
+}
+func (m *Bytes32) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_Bytes32.Merge(m, src)
+}
+func (m *Bytes32) XXX_Size() int {
+	return xxx_messageInfo_Bytes32.Size(m)
+}
+func (m *Bytes32) XXX_DiscardUnknown() {
+	xxx_messageInfo_Bytes32.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_Bytes32 proto.InternalMessageInfo
+
+func (m *Bytes32) GetData() []byte {
+	if m != nil {
+		return m.Data
+	}
+	return nil
+}
+
+type BigInt struct {
+	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *BigInt) Reset()         { *m = BigInt{} }
+func (m *BigInt) String() string { return proto.CompactTextString(m) }
+func (*BigInt) ProtoMessage()    {}
+func (*BigInt) Descriptor() ([]byte, []int) {
+	return fileDescriptor_fc4a30c7a1e70305, []int{1}
+}
+func (m *BigInt) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_BigInt.Unmarshal(m, b)
+}
+func (m *BigInt) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_BigInt.Marshal(b, m, deterministic)
+}
+func (m *BigInt) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_BigInt.Merge(m, src)
+}
+func (m *BigInt) XXX_Size() int {
+	return xxx_messageInfo_BigInt.Size(m)
+}
+func (m *BigInt) XXX_DiscardUnknown() {
+	xxx_messageInfo_BigInt.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_BigInt proto.InternalMessageInfo
+
+func (m *BigInt) GetData() []byte {
+	if m != nil {
+		return m.Data
+	}
+	return nil
+}
+
+type Hash struct {
+	Hash                 []byte   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *Hash) Reset()         { *m = Hash{} }
+func (m *Hash) String() string { return proto.CompactTextString(m) }
+func (*Hash) ProtoMessage()    {}
+func (*Hash) Descriptor() ([]byte, []int) {
+	return fileDescriptor_fc4a30c7a1e70305, []int{2}
+}
+func (m *Hash) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_Hash.Unmarshal(m, b)
+}
+func (m *Hash) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_Hash.Marshal(b, m, deterministic)
+}
+func (m *Hash) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_Hash.Merge(m, src)
+}
+func (m *Hash) XXX_Size() int {
+	return xxx_messageInfo_Hash.Size(m)
+}
+func (m *Hash) XXX_DiscardUnknown() {
+	xxx_messageInfo_Hash.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_Hash proto.InternalMessageInfo
+
+func (m *Hash) GetHash() []byte {
+	if m != nil {
+		return m.Hash
+	}
+	return nil
+}
+
+type Address struct {
+	Address              []byte   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
+	XXX_NoUnkeyedLiteral struct{} `json:"-"`
+	XXX_unrecognized     []byte   `json:"-"`
+	XXX_sizecache        int32    `json:"-"`
+}
+
+func (m *Address) Reset()         { *m = Address{} }
+func (m *Address) String() string { return proto.CompactTextString(m) }
+func (*Address) ProtoMessage()    {}
+func (*Address) Descriptor() ([]byte, []int) {
+	return fileDescriptor_fc4a30c7a1e70305, []int{3}
+}
+func (m *Address) XXX_Unmarshal(b []byte) error {
+	return xxx_messageInfo_Address.Unmarshal(m, b)
+}
+func (m *Address) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
+	return xxx_messageInfo_Address.Marshal(b, m, deterministic)
+}
+func (m *Address) XXX_Merge(src proto.Message) {
+	xxx_messageInfo_Address.Merge(m, src)
+}
+func (m *Address) XXX_Size() int {
+	return xxx_messageInfo_Address.Size(m)
+}
+func (m *Address) XXX_DiscardUnknown() {
+	xxx_messageInfo_Address.DiscardUnknown(m)
+}
+
+var xxx_messageInfo_Address proto.InternalMessageInfo
+
+func (m *Address) GetAddress() []byte {
+	if m != nil {
+		return m.Address
+	}
+	return nil
+}
+
+func init() {
+	proto.RegisterType((*Bytes32)(nil), "base.v1.Bytes32")
+	proto.RegisterType((*BigInt)(nil), "base.v1.BigInt")
+	proto.RegisterType((*Hash)(nil), "base.v1.Hash")
+	proto.RegisterType((*Address)(nil), "base.v1.Address")
+}
+
+func init() { proto.RegisterFile("base/v1/resource.proto", fileDescriptor_fc4a30c7a1e70305) }
+
+var fileDescriptor_fc4a30c7a1e70305 = []byte{
+	// 285 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x90, 0xc1, 0x4a, 0xc3, 0x40,
+	0x10, 0x86, 0x49, 0x2c, 0x8d, 0xac, 0x8a, 0x10, 0x41, 0x4a, 0x50, 0x94, 0x78, 0xf1, 0x62, 0x96,
+	0xb5, 0xb7, 0x7a, 0xea, 0x5e, 0xd4, 0x83, 0x10, 0x7a, 0x08, 0x45, 0x7a, 0xd9, 0x24, 0xe3, 0x26,
+	0xd0, 0x74, 0x4a, 0x66, 0x13, 0xe8, 0xbb, 0x78, 0xf2, 0xe8, 0xa3, 0xf8, 0x18, 0x1e, 0x7d, 0x0a,
+	0xd9, 0x24, 0xf5, 0xe4, 0x69, 0xbf, 0xfd, 0xff, 0x61, 0xf6, 0xff, 0x97, 0x9d, 0xa7, 0x8a, 0x80,
+	0xb7, 0x82, 0xd7, 0x40, 0xd8, 0xd4, 0x19, 0x44, 0xdb, 0x1a, 0x0d, 0xfa, 0x9e, 0xd5, 0xa3, 0x56,
+	0x04, 0x57, 0x1a, 0x51, 0xaf, 0x81, 0x77, 0x72, 0xda, 0xbc, 0x71, 0x53, 0x56, 0x40, 0x46, 0x55,
+	0xdb, 0x7e, 0x32, 0x38, 0xed, 0x36, 0x68, 0xd4, 0xd8, 0x0b, 0xe1, 0x25, 0xf3, 0xe4, 0xce, 0x00,
+	0x4d, 0xef, 0x7d, 0x9f, 0x8d, 0x72, 0x65, 0xd4, 0xc4, 0xb9, 0x76, 0x6e, 0x8f, 0x17, 0x1d, 0x87,
+	0x17, 0x6c, 0x2c, 0x4b, 0xfd, 0xbc, 0x31, 0xff, 0xba, 0x01, 0x1b, 0x3d, 0x29, 0x2a, 0xac, 0x57,
+	0x28, 0x2a, 0xf6, 0x9e, 0xe5, 0xf0, 0x86, 0x79, 0xf3, 0x3c, 0xaf, 0x81, 0xc8, 0x9f, 0x30, 0x4f,
+	0xf5, 0x38, 0x4c, 0xec, 0xaf, 0xf2, 0xdd, 0x61, 0x47, 0x19, 0x56, 0xd1, 0x90, 0x5f, 0x9e, 0x2c,
+	0x86, 0x62, 0xb1, 0x0d, 0x17, 0x3b, 0xaf, 0x73, 0x5d, 0x9a, 0xa2, 0x49, 0xa3, 0x0c, 0x2b, 0x8e,
+	0xf9, 0x8e, 0x08, 0x1a, 0xfa, 0x83, 0xbb, 0xae, 0x42, 0x86, 0x6b, 0xae, 0x61, 0xd3, 0x77, 0xe6,
+	0x1a, 0xf9, 0xf0, 0x49, 0x0f, 0xf6, 0x6c, 0xc5, 0x87, 0x7b, 0x20, 0x97, 0xcb, 0x4f, 0xd7, 0x93,
+	0xf6, 0x8d, 0x44, 0x7c, 0xf5, 0xb4, 0x4a, 0xc4, 0xb7, 0x7b, 0x36, 0xd0, 0xea, 0x31, 0x96, 0x2f,
+	0x60, 0x94, 0x2d, 0xf5, 0xe3, 0x1e, 0x5a, 0x75, 0x36, 0x4b, 0x44, 0x3a, 0xee, 0x76, 0x4e, 0x7f,
+	0x03, 0x00, 0x00, 0xff, 0xff, 0x9a, 0xf6, 0x4a, 0xeb, 0x78, 0x01, 0x00, 0x00,
+}

gen/proto/go/nodemanager/v1/resource.pb.go

+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: nodemanager/v1/resource.proto
+
+package nodemanagerv1
+
+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
+
+func init() { proto.RegisterFile("nodemanager/v1/resource.proto", fileDescriptor_462e4441103de524) }
+
+var fileDescriptor_462e4441103de524 = []byte{
+	// 181 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0xcd, 0xcb, 0x4f, 0x49,
+	0xcd, 0x4d, 0xcc, 0x4b, 0x4c, 0x4f, 0x2d, 0xd2, 0x2f, 0x33, 0xd4, 0x2f, 0x4a, 0x2d, 0xce, 0x2f,
+	0x2d, 0x4a, 0x4e, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0xe2, 0x43, 0x92, 0xd6, 0x2b, 0x33,
+	0x74, 0x3a, 0xcb, 0xc8, 0x25, 0x94, 0x9c, 0x9f, 0xab, 0x87, 0x26, 0xcc, 0x1b, 0x04, 0xd5, 0x16,
+	0x00, 0xd2, 0x15, 0xc0, 0x18, 0xe5, 0x9f, 0x9e, 0x59, 0x92, 0x51, 0x9a, 0xa4, 0x97, 0x9c, 0x9f,
+	0xab, 0x9f, 0x9f, 0x52, 0x59, 0x5c, 0x9c, 0x5a, 0x5a, 0x0c, 0x67, 0xe8, 0x82, 0xcd, 0x4e, 0xce,
+	0xcf, 0xd1, 0x4f, 0x4f, 0xcd, 0xd3, 0x07, 0x73, 0xf4, 0xd3, 0xf3, 0xf5, 0x51, 0x5d, 0x62, 0x8d,
+	0xc4, 0x2d, 0x33, 0x5c, 0xc4, 0xc4, 0xec, 0x17, 0x11, 0xb1, 0x8a, 0x89, 0xcf, 0x0f, 0xc9, 0xe2,
+	0x30, 0xc3, 0x53, 0x28, 0x02, 0x31, 0x61, 0x86, 0x8f, 0x98, 0xa4, 0x50, 0x05, 0x62, 0xdc, 0x03,
+	0x9c, 0x7c, 0x53, 0x4b, 0x12, 0x53, 0x12, 0x4b, 0x12, 0x5f, 0x31, 0xf1, 0x23, 0x49, 0x5a, 0x59,
+	0x85, 0x19, 0x26, 0xb1, 0x81, 0x6d, 0x37, 0x06, 0x04, 0x00, 0x00, 0xff, 0xff, 0xa4, 0x5d, 0x07,
+	0x12, 0x07, 0x01, 0x00, 0x00,
+}

gen/proto/go/nodemanager/v1/service.pb.go

+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: nodemanager/v1/service.proto
+
+package nodemanagerv1
+
+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
+
+func init() { proto.RegisterFile("nodemanager/v1/service.proto", fileDescriptor_085790cc5673c432) }
+
+var fileDescriptor_085790cc5673c432 = []byte{
+	// 296 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x7c, 0x90, 0xb1, 0x4a, 0xc4, 0x40,
+	0x10, 0x86, 0x2f, 0x11, 0x2c, 0xc2, 0x11, 0x61, 0xcb, 0xa0, 0x16, 0xa7, 0x82, 0x8d, 0x59, 0x57,
+	0xbb, 0xb3, 0x0b, 0x82, 0x55, 0x62, 0x38, 0x35, 0x1e, 0x7a, 0x20, 0x7b, 0xc9, 0xb0, 0x17, 0xce,
+	0x64, 0xe3, 0xce, 0x26, 0xe0, 0xeb, 0x58, 0xfa, 0x24, 0x22, 0x3e, 0x85, 0xa5, 0x4f, 0x21, 0x26,
+	0x41, 0x92, 0x14, 0xd7, 0xed, 0xcc, 0xf7, 0xcf, 0xfc, 0xfb, 0x8f, 0xb5, 0x9b, 0xcb, 0x04, 0x32,
+	0x9e, 0x73, 0x01, 0x8a, 0x56, 0x8c, 0x22, 0xa8, 0x2a, 0x8d, 0xc1, 0x2d, 0x94, 0xd4, 0x92, 0xd8,
+	0x1d, 0xea, 0x56, 0xcc, 0x39, 0x1a, 0xa8, 0x15, 0xbc, 0x94, 0x80, 0xfa, 0x49, 0x01, 0x16, 0x32,
+	0xc7, 0x76, 0xec, 0xec, 0xc3, 0xb0, 0x48, 0x20, 0x13, 0xf0, 0x1b, 0xe5, 0x4d, 0xb3, 0x93, 0xdc,
+	0x59, 0xf6, 0x0c, 0x44, 0x8a, 0x1a, 0xd4, 0xbd, 0x54, 0x6b, 0x50, 0x64, 0xcf, 0xed, 0x1b, 0xb8,
+	0x4d, 0xdf, 0x07, 0x44, 0x2e, 0xc0, 0xd9, 0x1f, 0xe2, 0x76, 0x61, 0xcb, 0x27, 0xa3, 0x63, 0xe3,
+	0xd4, 0x20, 0x8f, 0xd6, 0xf8, 0x32, 0xc5, 0x82, 0xeb, 0x78, 0x75, 0xcb, 0x71, 0x4d, 0x0e, 0x86,
+	0x53, 0x5d, 0x3a, 0x6b, 0x7e, 0xec, 0x1c, 0x6e, 0x16, 0x35, 0x71, 0x26, 0x23, 0xef, 0xcb, 0xb0,
+	0x48, 0x2c, 0xb3, 0x81, 0xda, 0x1b, 0xb7, 0x99, 0xc2, 0xbf, 0xbc, 0xa1, 0xf1, 0x70, 0x2d, 0x52,
+	0xbd, 0x2a, 0x97, 0x6e, 0x2c, 0x33, 0x2a, 0x93, 0x57, 0x44, 0x28, 0xf1, 0xff, 0x71, 0x52, 0x5f,
+	0x25, 0x96, 0xcf, 0x54, 0x40, 0x4e, 0xeb, 0x82, 0x0a, 0x49, 0xfb, 0xb7, 0xbc, 0xe8, 0x94, 0x15,
+	0x7b, 0x33, 0xb7, 0x82, 0xf9, 0xfc, 0xdd, 0xb4, 0x83, 0x8e, 0x6f, 0xc4, 0x3e, 0x7b, 0x8d, 0x45,
+	0xc4, 0xbe, 0x4d, 0xa7, 0xdf, 0x58, 0x5c, 0x85, 0x9e, 0x0f, 0x9a, 0x27, 0x5c, 0xf3, 0x1f, 0x73,
+	0xa7, 0x03, 0xa7, 0xd3, 0x88, 0x2d, 0xb7, 0x6b, 0xf7, 0xf3, 0xdf, 0x00, 0x00, 0x00, 0xff, 0xff,
+	0xb9, 0x2f, 0xc2, 0xe0, 0xf7, 0x01, 0x00, 0x00,
+}

gen/proto/go/nodemanager/v1/service_grpc.pb.go

+// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-grpc v1.2.0
+// - protoc             (unknown)
+// source: nodemanager/v1/service.proto
+
+package nodemanagerv1
+
+import (
+	context "context"
+	grpc "google.golang.org/grpc"
+	codes "google.golang.org/grpc/codes"
+	status "google.golang.org/grpc/status"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+// Requires gRPC-Go v1.32.0 or later.
+const _ = grpc.SupportPackageIsVersion7
+
+// NodeManagerServiceClient is the client API for NodeManagerService service.
+//
+// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
+type NodeManagerServiceClient interface {
+	RegisterWorker(ctx context.Context, opts ...grpc.CallOption) (NodeManagerService_RegisterWorkerClient, error)
+	DispatchTask(ctx context.Context, in *DispatchTaskRequest, opts ...grpc.CallOption) (*DispatchTaskResponse, error)
+}
+
+type nodeManagerServiceClient struct {
+	cc grpc.ClientConnInterface
+}
+
+func NewNodeManagerServiceClient(cc grpc.ClientConnInterface) NodeManagerServiceClient {
+	return &nodeManagerServiceClient{cc}
+}
+
+func (c *nodeManagerServiceClient) RegisterWorker(ctx context.Context, opts ...grpc.CallOption) (NodeManagerService_RegisterWorkerClient, error) {
+	stream, err := c.cc.NewStream(ctx, &NodeManagerService_ServiceDesc.Streams[0], "/nodemanager.v1.NodeManagerService/RegisterWorker", opts...)
+	if err != nil {
+		return nil, err
+	}
+	x := &nodeManagerServiceRegisterWorkerClient{stream}
+	return x, nil
+}
+
+type NodeManagerService_RegisterWorkerClient interface {
+	Send(*WorkerMessage) error
+	Recv() (*ManagerMessage, error)
+	grpc.ClientStream
+}
+
+type nodeManagerServiceRegisterWorkerClient struct {
+	grpc.ClientStream
+}
+
+func (x *nodeManagerServiceRegisterWorkerClient) Send(m *WorkerMessage) error {
+	return x.ClientStream.SendMsg(m)
+}
+
+func (x *nodeManagerServiceRegisterWorkerClient) Recv() (*ManagerMessage, error) {
+	m := new(ManagerMessage)
+	if err := x.ClientStream.RecvMsg(m); err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+func (c *nodeManagerServiceClient) DispatchTask(ctx context.Context, in *DispatchTaskRequest, opts ...grpc.CallOption) (*DispatchTaskResponse, error) {
+	out := new(DispatchTaskResponse)
+	err := c.cc.Invoke(ctx, "/nodemanager.v1.NodeManagerService/DispatchTask", in, out, opts...)
+	if err != nil {
+		return nil, err
+	}
+	return out, nil
+}
+
+// NodeManagerServiceServer is the server API for NodeManagerService service.
+// All implementations must embed UnimplementedNodeManagerServiceServer
+// for forward compatibility
+type NodeManagerServiceServer interface {
+	RegisterWorker(NodeManagerService_RegisterWorkerServer) error
+	DispatchTask(context.Context, *DispatchTaskRequest) (*DispatchTaskResponse, error)
+	mustEmbedUnimplementedNodeManagerServiceServer()
+}
+
+// UnimplementedNodeManagerServiceServer must be embedded to have forward compatible implementations.
+type UnimplementedNodeManagerServiceServer struct {
+}
+
+func (UnimplementedNodeManagerServiceServer) RegisterWorker(NodeManagerService_RegisterWorkerServer) error {
+	return status.Errorf(codes.Unimplemented, "method RegisterWorker not implemented")
+}
+func (UnimplementedNodeManagerServiceServer) DispatchTask(context.Context, *DispatchTaskRequest) (*DispatchTaskResponse, error) {
+	return nil, status.Errorf(codes.Unimplemented, "method DispatchTask not implemented")
+}
+func (UnimplementedNodeManagerServiceServer) mustEmbedUnimplementedNodeManagerServiceServer() {}
+
+// UnsafeNodeManagerServiceServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to NodeManagerServiceServer will
+// result in compilation errors.
+type UnsafeNodeManagerServiceServer interface {
+	mustEmbedUnimplementedNodeManagerServiceServer()
+}
+
+func RegisterNodeManagerServiceServer(s grpc.ServiceRegistrar, srv NodeManagerServiceServer) {
+	s.RegisterService(&NodeManagerService_ServiceDesc, srv)
+}
+
+func _NodeManagerService_RegisterWorker_Handler(srv interface{}, stream grpc.ServerStream) error {
+	return srv.(NodeManagerServiceServer).RegisterWorker(&nodeManagerServiceRegisterWorkerServer{stream})
+}
+
+type NodeManagerService_RegisterWorkerServer interface {
+	Send(*ManagerMessage) error
+	Recv() (*WorkerMessage, error)
+	grpc.ServerStream
+}
+
+type nodeManagerServiceRegisterWorkerServer struct {
+	grpc.ServerStream
+}
+
+func (x *nodeManagerServiceRegisterWorkerServer) Send(m *ManagerMessage) error {
+	return x.ServerStream.SendMsg(m)
+}
+
+func (x *nodeManagerServiceRegisterWorkerServer) Recv() (*WorkerMessage, error) {
+	m := new(WorkerMessage)
+	if err := x.ServerStream.RecvMsg(m); err != nil {
+		return nil, err
+	}
+	return m, nil
+}
+
+func _NodeManagerService_DispatchTask_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
+	in := new(DispatchTaskRequest)
+	if err := dec(in); err != nil {
+		return nil, err
+	}
+	if interceptor == nil {
+		return srv.(NodeManagerServiceServer).DispatchTask(ctx, in)
+	}
+	info := &grpc.UnaryServerInfo{
+		Server:     srv,
+		FullMethod: "/nodemanager.v1.NodeManagerService/DispatchTask",
+	}
+	handler := func(ctx context.Context, req interface{}) (interface{}, error) {
+		return srv.(NodeManagerServiceServer).DispatchTask(ctx, req.(*DispatchTaskRequest))
+	}
+	return interceptor(ctx, in, info, handler)
+}
+
+// NodeManagerService_ServiceDesc is the grpc.ServiceDesc for NodeManagerService service.
+// It's only intended for direct use with grpc.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var NodeManagerService_ServiceDesc = grpc.ServiceDesc{
+	ServiceName: "nodemanager.v1.NodeManagerService",
+	HandlerType: (*NodeManagerServiceServer)(nil),
+	Methods: []grpc.MethodDesc{
+		{
+			MethodName: "DispatchTask",
+			Handler:    _NodeManagerService_DispatchTask_Handler,
+		},
+	},
+	Streams: []grpc.StreamDesc{
+		{
+			StreamName:    "RegisterWorker",
+			Handler:       _NodeManagerService_RegisterWorker_Handler,
+			ServerStreams: true,
+			ClientStreams: true,
+		},
+	},
+	Metadata: "nodemanager/v1/service.proto",
+}

gen/proto/go/scheduler/v1/request_response.pb.go

+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: scheduler/v1/request_response.proto
+
+package schedulerv1
+
+import (
+	fmt "fmt"
+	proto "github.com/gogo/protobuf/proto"
+	_ "github.com/gogo/protobuf/types"
+	_ "google.golang.org/protobuf/types/known/fieldmaskpb"
+	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
+
+func init() {
+	proto.RegisterFile("scheduler/v1/request_response.proto", fileDescriptor_c6075862f978c335)
+}
+
+var fileDescriptor_c6075862f978c335 = []byte{
+	// 243 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x52, 0x2e, 0x4e, 0xce, 0x48,
+	0x4d, 0x29, 0xcd, 0x49, 0x2d, 0xd2, 0x2f, 0x33, 0xd4, 0x2f, 0x4a, 0x2d, 0x2c, 0x4d, 0x2d, 0x2e,
+	0x89, 0x2f, 0x4a, 0x2d, 0x2e, 0xc8, 0xcf, 0x2b, 0x4e, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17,
+	0xe2, 0x81, 0x2b, 0xd2, 0x2b, 0x33, 0x94, 0x52, 0x48, 0xcf, 0xcf, 0x4f, 0xcf, 0x49, 0xd5, 0x07,
+	0xcb, 0x25, 0x95, 0xa6, 0xe9, 0xa7, 0x65, 0xa6, 0xe6, 0xa4, 0xc4, 0xe7, 0x26, 0x16, 0x67, 0x43,
+	0xd4, 0x4b, 0xc9, 0xa3, 0xab, 0x28, 0xc9, 0xcc, 0x4d, 0x2d, 0x2e, 0x49, 0xcc, 0x2d, 0x80, 0x2a,
+	0x90, 0x46, 0xb3, 0xb5, 0x38, 0xbf, 0xb4, 0x28, 0x19, 0x6a, 0x9b, 0xd3, 0x31, 0x46, 0x2e, 0x81,
+	0xe4, 0xfc, 0x5c, 0x3d, 0x64, 0x4b, 0x9d, 0x44, 0x82, 0x20, 0x4e, 0x0b, 0x82, 0xba, 0x2c, 0x00,
+	0xa4, 0x34, 0x80, 0x31, 0xca, 0x3b, 0x3d, 0xb3, 0x24, 0xa3, 0x34, 0x49, 0x2f, 0x39, 0x3f, 0x57,
+	0x3f, 0x3f, 0xa5, 0xb2, 0xb8, 0x38, 0xb5, 0xb4, 0x18, 0xce, 0xd0, 0x05, 0x1b, 0x98, 0x9c, 0x9f,
+	0xa3, 0x9f, 0x9e, 0x9a, 0x07, 0x71, 0x8d, 0x7e, 0x7a, 0xbe, 0x3e, 0xb2, 0xe5, 0xd6, 0x70, 0x4e,
+	0x99, 0xe1, 0x22, 0x26, 0xe6, 0xe0, 0x88, 0x88, 0x55, 0x4c, 0x3c, 0xc1, 0x70, 0x9b, 0xc3, 0x0c,
+	0x4f, 0x21, 0x71, 0x63, 0xc2, 0x0c, 0x1f, 0x31, 0x49, 0x20, 0x73, 0x63, 0xdc, 0x03, 0x9c, 0x7c,
+	0x53, 0x4b, 0x12, 0x53, 0x12, 0x4b, 0x12, 0x5f, 0x31, 0xf1, 0xc2, 0xa5, 0xac, 0xac, 0xc2, 0x0c,
+	0x93, 0xd8, 0xc0, 0x36, 0x1a, 0x03, 0x02, 0x00, 0x00, 0xff, 0xff, 0x8c, 0x95, 0x9b, 0x82, 0x64,
+	0x01, 0x00, 0x00,
+}

gen/proto/go/scheduler/v1/resource.pb.go

+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: scheduler/v1/resource.proto
+
+package schedulerv1
+
+import (
+	fmt "fmt"
+	proto "github.com/gogo/protobuf/proto"
+	_ "github.com/odysseus/odysseus-protocol/gen/proto/go/base/v1"
+	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
+
+func init() { proto.RegisterFile("scheduler/v1/resource.proto", fileDescriptor_e8c3445506ce0bc0) }
+
+var fileDescriptor_e8c3445506ce0bc0 = []byte{
+	// 188 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x2e, 0x4e, 0xce, 0x48,
+	0x4d, 0x29, 0xcd, 0x49, 0x2d, 0xd2, 0x2f, 0x33, 0xd4, 0x2f, 0x4a, 0x2d, 0xce, 0x2f, 0x2d, 0x4a,
+	0x4e, 0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0xe2, 0x81, 0x4b, 0xea, 0x95, 0x19, 0x4a, 0x89,
+	0x25, 0x25, 0x16, 0xa7, 0x62, 0xaa, 0x72, 0xda, 0xcf, 0xc8, 0x25, 0x90, 0x9c, 0x9f, 0xab, 0x87,
+	0xac, 0xd8, 0x89, 0x37, 0x08, 0xaa, 0x28, 0x00, 0xa4, 0x26, 0x80, 0x31, 0xca, 0x3b, 0x3d, 0xb3,
+	0x24, 0xa3, 0x34, 0x49, 0x2f, 0x39, 0x3f, 0x57, 0x3f, 0x3f, 0xa5, 0xb2, 0xb8, 0x38, 0xb5, 0xb4,
+	0x18, 0xce, 0xd0, 0x05, 0x9b, 0x94, 0x9c, 0x9f, 0xa3, 0x9f, 0x9e, 0x9a, 0xa7, 0x0f, 0xe6, 0xe8,
+	0xa7, 0xe7, 0xeb, 0x23, 0xbb, 0xcd, 0x1a, 0xce, 0x29, 0x33, 0x5c, 0xc4, 0xc4, 0x1c, 0x1c, 0x11,
+	0xb1, 0x8a, 0x89, 0x27, 0x18, 0x6e, 0x65, 0x98, 0xe1, 0x29, 0x24, 0x6e, 0x4c, 0x98, 0xe1, 0x23,
+	0x26, 0x09, 0x64, 0x6e, 0x8c, 0x7b, 0x80, 0x93, 0x6f, 0x6a, 0x49, 0x62, 0x4a, 0x62, 0x49, 0xe2,
+	0x2b, 0x26, 0x5e, 0xb8, 0x94, 0x95, 0x55, 0x98, 0x61, 0x12, 0x1b, 0xd8, 0x46, 0x63, 0x40, 0x00,
+	0x00, 0x00, 0xff, 0xff, 0x36, 0x6a, 0x4c, 0x58, 0x0d, 0x01, 0x00, 0x00,
+}

gen/proto/go/scheduler/v1/service.pb.go

+// Code generated by protoc-gen-gogo. DO NOT EDIT.
+// source: scheduler/v1/service.proto
+
+package schedulerv1
+
+import (
+	fmt "fmt"
+	proto "github.com/gogo/protobuf/proto"
+	_ "google.golang.org/protobuf/types/known/emptypb"
+	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
+
+func init() { proto.RegisterFile("scheduler/v1/service.proto", fileDescriptor_ae09295ad7002c58) }
+
+var fileDescriptor_ae09295ad7002c58 = []byte{
+	// 230 bytes of a gzipped FileDescriptorProto
+	0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xe2, 0x92, 0x2a, 0x4e, 0xce, 0x48,
+	0x4d, 0x29, 0xcd, 0x49, 0x2d, 0xd2, 0x2f, 0x33, 0xd4, 0x2f, 0x4e, 0x2d, 0x2a, 0xcb, 0x4c, 0x4e,
+	0xd5, 0x2b, 0x28, 0xca, 0x2f, 0xc9, 0x17, 0xe2, 0x81, 0xcb, 0xe9, 0x95, 0x19, 0x4a, 0x49, 0xa7,
+	0xe7, 0xe7, 0xa7, 0xe7, 0xa4, 0xea, 0x83, 0xe5, 0x92, 0x4a, 0xd3, 0xf4, 0x53, 0x73, 0x0b, 0x4a,
+	0x2a, 0x21, 0x4a, 0xa5, 0x94, 0x51, 0x8c, 0x29, 0x4a, 0x2d, 0x2c, 0x4d, 0x2d, 0x2e, 0x89, 0x2f,
+	0x4a, 0x2d, 0x2e, 0xc8, 0xcf, 0x2b, 0x86, 0x9a, 0x67, 0x24, 0xc4, 0x25, 0x10, 0x0c, 0x53, 0x16,
+	0x0c, 0xb1, 0xc9, 0x69, 0x1f, 0x23, 0x97, 0x40, 0x72, 0x7e, 0xae, 0x1e, 0xb2, 0x55, 0x4e, 0x3c,
+	0x50, 0xd9, 0x00, 0x90, 0xb6, 0x00, 0xc6, 0x28, 0xef, 0xf4, 0xcc, 0x92, 0x8c, 0xd2, 0x24, 0xbd,
+	0xe4, 0xfc, 0x5c, 0xfd, 0xfc, 0x94, 0xca, 0xe2, 0xe2, 0xd4, 0xd2, 0x62, 0x38, 0x43, 0x17, 0x6c,
+	0x78, 0x72, 0x7e, 0x8e, 0x7e, 0x7a, 0x6a, 0x1e, 0xc4, 0x75, 0xfa, 0xe9, 0xf9, 0xfa, 0xc8, 0x0e,
+	0xb2, 0x86, 0x73, 0xca, 0x0c, 0x17, 0x31, 0x31, 0x07, 0x47, 0x44, 0xac, 0x62, 0xe2, 0x81, 0x3b,
+	0x45, 0x2f, 0xcc, 0xf0, 0x14, 0x12, 0x37, 0x26, 0xcc, 0xf0, 0x11, 0x93, 0x04, 0x32, 0x37, 0xc6,
+	0x3d, 0xc0, 0xc9, 0x37, 0xb5, 0x24, 0x31, 0x25, 0xb1, 0x24, 0xf1, 0x15, 0x13, 0x2f, 0x5c, 0xca,
+	0xca, 0x2a, 0xcc, 0x30, 0x89, 0x0d, 0x6c, 0xa3, 0x31, 0x20, 0x00, 0x00, 0xff, 0xff, 0xa8, 0x48,
+	0x03, 0x2b, 0x49, 0x01, 0x00, 0x00,
+}

gen/proto/go/scheduler/v1/service_grpc.pb.go

+// Code generated by protoc-gen-go-grpc. DO NOT EDIT.
+// versions:
+// - protoc-gen-go-grpc v1.2.0
+// - protoc             (unknown)
+// source: scheduler/v1/service.proto
+
+package schedulerv1
+
+import (
+	grpc "google.golang.org/grpc"
+)
+
+// This is a compile-time assertion to ensure that this generated file
+// is compatible with the grpc package it is being compiled against.
+// Requires gRPC-Go v1.32.0 or later.
+const _ = grpc.SupportPackageIsVersion7
+
+// SchedulerServiceClient is the client API for SchedulerService service.
+//
+// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
+type SchedulerServiceClient interface {
+}
+
+type schedulerServiceClient struct {
+	cc grpc.ClientConnInterface
+}
+
+func NewSchedulerServiceClient(cc grpc.ClientConnInterface) SchedulerServiceClient {
+	return &schedulerServiceClient{cc}
+}
+
+// SchedulerServiceServer is the server API for SchedulerService service.
+// All implementations must embed UnimplementedSchedulerServiceServer
+// for forward compatibility
+type SchedulerServiceServer interface {
+	mustEmbedUnimplementedSchedulerServiceServer()
+}
+
+// UnimplementedSchedulerServiceServer must be embedded to have forward compatible implementations.
+type UnimplementedSchedulerServiceServer struct {
+}
+
+func (UnimplementedSchedulerServiceServer) mustEmbedUnimplementedSchedulerServiceServer() {}
+
+// UnsafeSchedulerServiceServer may be embedded to opt out of forward compatibility for this service.
+// Use of this interface is not recommended, as added methods to SchedulerServiceServer will
+// result in compilation errors.
+type UnsafeSchedulerServiceServer interface {
+	mustEmbedUnimplementedSchedulerServiceServer()
+}
+
+func RegisterSchedulerServiceServer(s grpc.ServiceRegistrar, srv SchedulerServiceServer) {
+	s.RegisterService(&SchedulerService_ServiceDesc, srv)
+}
+
+// SchedulerService_ServiceDesc is the grpc.ServiceDesc for SchedulerService service.
+// It's only intended for direct use with grpc.RegisterService,
+// and not to be introspected or modified (even as a copy)
+var SchedulerService_ServiceDesc = grpc.ServiceDesc{
+	ServiceName: "scheduler.v1.SchedulerService",
+	HandlerType: (*SchedulerServiceServer)(nil),
+	Methods:     []grpc.MethodDesc{},
+	Streams:     []grpc.StreamDesc{},
+	Metadata:    "scheduler/v1/service.proto",
+}

go.mod

+module github.com/odysseus/odysseus-protocol
+
+go 1.18
+
+require (
+	github.com/gogo/protobuf v1.3.2
+	google.golang.org/grpc v1.60.1
+	google.golang.org/protobuf v1.32.0
+)
+
+require (
+	github.com/golang/protobuf v1.5.3 // indirect
+	golang.org/x/net v0.16.0 // indirect
+	golang.org/x/sys v0.13.0 // indirect
+	golang.org/x/text v0.13.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20231002182017-d307bd883b97 // indirect
+)

go.sum

+github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=
+github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=
+github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
+github.com/golang/protobuf v1.5.3 h1:KhyjKVUg7Usr/dYsdSqoFveMYd5ko72D+zANwlG1mmg=
+github.com/golang/protobuf v1.5.3/go.mod h1:XVQd3VNwM+JqD3oG2Ue2ip4fOMUkwXdXDdiuN0vRsmY=
+github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
+github.com/google/go-cmp v0.5.9 h1:O2Tfq5qg4qc4AmwVlvv0oLiVAGB7enBSJ2x2DqQFi38=
+github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=
+github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=
+github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
+github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
+golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
+golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
+golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=
+golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
+golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
+golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=
+golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=
+golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=
+golang.org/x/net v0.16.0 h1:7eBu7KsSvFDtSXUIDbh3aqlK4DPsZ1rByC8PFfBThos=
+golang.org/x/net v0.16.0/go.mod h1:NxSsAGuq816PNPmqtQdLE42eU2Fs7NoRIZrHJAlaCOE=
+golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
+golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
+golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
+golang.org/x/sys v0.13.0 h1:Af8nKPmuFypiUBjVoU9V20FiaFXOcuZI21p0ycVYYGE=
+golang.org/x/sys v0.13.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
+golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
+golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
+golang.org/x/text v0.13.0 h1:ablQoSUd0tRdKxZewP80B+BaqeKJuVhuRxj/dkrun3k=
+golang.org/x/text v0.13.0/go.mod h1:TvPlkZtksWOMsz7fbANvkp4WM8x/WCo/om8BMLbz+aE=
+golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
+golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=
+golang.org/x/tools v0.0.0-20200619180055-7c47624df98f/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=
+golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=
+golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20231002182017-d307bd883b97 h1:6GQBEOdGkX6MMTLT9V+TjtIRZCw9VPD5Z+yHY9wMgS0=
+google.golang.org/genproto/googleapis/rpc v0.0.0-20231002182017-d307bd883b97/go.mod h1:v7nGkzlmW8P3n/bKmWBn2WpBjpOEx8Q6gMueudAmKfY=
+google.golang.org/grpc v1.60.1 h1:26+wFr+cNqSGFcOXcabYC0lUVJVRa2Sb2ortSK7VrEU=
+google.golang.org/grpc v1.60.1/go.mod h1:OlCHIeLYqSSsLi6i49B5QGdzaMZK9+M7LXN2FKz4eGM=
+google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
+google.golang.org/protobuf v1.26.0/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
+google.golang.org/protobuf v1.32.0 h1:pPC6BG5ex8PDFnkbrGU3EixyhKcQ2aDuBS36lqK/C7I=
+google.golang.org/protobuf v1.32.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=

main.go

+package main
+
+func main() {
+	println("Hello, World!")
+}
\ No newline at end of file

nodemanager/nodemanager/v1/request_response.proto

@@ -29,7 +29,7 @@ message HeartbeatResponse {
 
 message StatusResp {
   uint64 remain_power = 1;
-  uint remain_device = 2; // 剩余
+  uint64 remain_device = 2; // 剩余
 }
 
 message PushTaskMessage {
@@ -48,6 +48,11 @@ message DispatchTaskRequest {
   string worker = 3;
 }
 
+message DispatchTaskResponse {
+  string task_id = 1;
+  string worker = 2;
+}
+
 message DeviceInfo {
   // device info for gpu
   string device_name = 1;

nodemanager/nodemanager/v1/service.proto

@@ -6,5 +6,5 @@ import "nodemanager/v1/request_response.proto";
 service NodeManagerService {
   rpc RegisterWorker(stream WorkerMessage) returns (stream ManagerMessage) {}
 
-  rpc DispatchTask(DispatchTaskRequest) returns () {}
+  rpc DispatchTask(DispatchTaskRequest) returns (DispatchTaskResponse) {}
 }

scheduler/scheduler/v1/service.proto

@@ -4,14 +4,6 @@ package scheduler.v1;
 
 import "google/protobuf/empty.proto";
 import "scheduler/v1/request_response.proto";
-import "scheduler/v1/web3.proto";
-import "base/v1/eth_blocks.proto";
-
 
 service SchedulerService {
-  // block info service 
-  rpc BlockNumber(google.protobuf.Empty) returns (HeightResponse) {};
-  rpc BlockTransactionCountByHash(BlockTransactionCountByHashRequest) returns (BlockTransactionCountByHashResponse) {};
-  // subscribe service
-  rpc SubscribeNewTx(google.protobuf.Empty) returns (stream SubscribeNewTxResponse) {}
 }