From cc85104ec063a58df756f411a55cc7d4ed907166 Mon Sep 17 00:00:00 2001 From: h0n9 Date: Fri, 10 May 2024 15:28:21 +0900 Subject: [PATCH 1/2] feat: Add is_encrypted field to MsgCapsule in msg-lake.proto --- proto/msg-lake.proto | 1 + 1 file changed, 1 insertion(+) diff --git a/proto/msg-lake.proto b/proto/msg-lake.proto index 1f85057..c3000b8 100644 --- a/proto/msg-lake.proto +++ b/proto/msg-lake.proto @@ -42,6 +42,7 @@ message MsgCapsule { bytes data = 1; Signature signature = 2; int64 timestamp = 3; + bool is_encrypted = 4; } message Signature { From 8d4af835c76376e8ab611f411cb6171b67adefa9 Mon Sep 17 00:00:00 2001 From: h0n9 Date: Fri, 10 May 2024 15:29:06 +0900 Subject: [PATCH 2/2] chore: Update proto file metadata path to "proto/msg-lake.proto" --- proto/msg-lake.pb.go | 237 ++++++++++++++++++++------------------ proto/msg-lake_grpc.pb.go | 6 +- 2 files changed, 127 insertions(+), 116 deletions(-) diff --git a/proto/msg-lake.pb.go b/proto/msg-lake.pb.go index 1285144..c2fec65 100644 --- a/proto/msg-lake.pb.go +++ b/proto/msg-lake.pb.go @@ -1,8 +1,8 @@ // Code generated by protoc-gen-go. DO NOT EDIT. // versions: -// protoc-gen-go v1.30.0 -// protoc v4.25.0 -// source: msg-lake.proto +// protoc-gen-go v1.33.0 +// protoc v5.26.1 +// source: proto/msg-lake.proto package proto @@ -53,11 +53,11 @@ func (x SubscribeResType) String() string { } func (SubscribeResType) Descriptor() protoreflect.EnumDescriptor { - return file_msg_lake_proto_enumTypes[0].Descriptor() + return file_proto_msg_lake_proto_enumTypes[0].Descriptor() } func (SubscribeResType) Type() protoreflect.EnumType { - return &file_msg_lake_proto_enumTypes[0] + return &file_proto_msg_lake_proto_enumTypes[0] } func (x SubscribeResType) Number() protoreflect.EnumNumber { @@ -66,7 +66,7 @@ func (x SubscribeResType) Number() protoreflect.EnumNumber { // Deprecated: Use SubscribeResType.Descriptor instead. func (SubscribeResType) EnumDescriptor() ([]byte, []int) { - return file_msg_lake_proto_rawDescGZIP(), []int{0} + return file_proto_msg_lake_proto_rawDescGZIP(), []int{0} } type PublishReq struct { @@ -81,7 +81,7 @@ type PublishReq struct { func (x *PublishReq) Reset() { *x = PublishReq{} if protoimpl.UnsafeEnabled { - mi := &file_msg_lake_proto_msgTypes[0] + mi := &file_proto_msg_lake_proto_msgTypes[0] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -94,7 +94,7 @@ func (x *PublishReq) String() string { func (*PublishReq) ProtoMessage() {} func (x *PublishReq) ProtoReflect() protoreflect.Message { - mi := &file_msg_lake_proto_msgTypes[0] + mi := &file_proto_msg_lake_proto_msgTypes[0] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -107,7 +107,7 @@ func (x *PublishReq) ProtoReflect() protoreflect.Message { // Deprecated: Use PublishReq.ProtoReflect.Descriptor instead. func (*PublishReq) Descriptor() ([]byte, []int) { - return file_msg_lake_proto_rawDescGZIP(), []int{0} + return file_proto_msg_lake_proto_rawDescGZIP(), []int{0} } func (x *PublishReq) GetTopicId() string { @@ -136,7 +136,7 @@ type PublishRes struct { func (x *PublishRes) Reset() { *x = PublishRes{} if protoimpl.UnsafeEnabled { - mi := &file_msg_lake_proto_msgTypes[1] + mi := &file_proto_msg_lake_proto_msgTypes[1] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -149,7 +149,7 @@ func (x *PublishRes) String() string { func (*PublishRes) ProtoMessage() {} func (x *PublishRes) ProtoReflect() protoreflect.Message { - mi := &file_msg_lake_proto_msgTypes[1] + mi := &file_proto_msg_lake_proto_msgTypes[1] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -162,7 +162,7 @@ func (x *PublishRes) ProtoReflect() protoreflect.Message { // Deprecated: Use PublishRes.ProtoReflect.Descriptor instead. func (*PublishRes) Descriptor() ([]byte, []int) { - return file_msg_lake_proto_rawDescGZIP(), []int{1} + return file_proto_msg_lake_proto_rawDescGZIP(), []int{1} } func (x *PublishRes) GetTopicId() string { @@ -191,7 +191,7 @@ type SubscribeReq struct { func (x *SubscribeReq) Reset() { *x = SubscribeReq{} if protoimpl.UnsafeEnabled { - mi := &file_msg_lake_proto_msgTypes[2] + mi := &file_proto_msg_lake_proto_msgTypes[2] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -204,7 +204,7 @@ func (x *SubscribeReq) String() string { func (*SubscribeReq) ProtoMessage() {} func (x *SubscribeReq) ProtoReflect() protoreflect.Message { - mi := &file_msg_lake_proto_msgTypes[2] + mi := &file_proto_msg_lake_proto_msgTypes[2] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -217,7 +217,7 @@ func (x *SubscribeReq) ProtoReflect() protoreflect.Message { // Deprecated: Use SubscribeReq.ProtoReflect.Descriptor instead. func (*SubscribeReq) Descriptor() ([]byte, []int) { - return file_msg_lake_proto_rawDescGZIP(), []int{2} + return file_proto_msg_lake_proto_rawDescGZIP(), []int{2} } func (x *SubscribeReq) GetTopicId() string { @@ -252,7 +252,7 @@ type SubscribeRes struct { func (x *SubscribeRes) Reset() { *x = SubscribeRes{} if protoimpl.UnsafeEnabled { - mi := &file_msg_lake_proto_msgTypes[3] + mi := &file_proto_msg_lake_proto_msgTypes[3] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -265,7 +265,7 @@ func (x *SubscribeRes) String() string { func (*SubscribeRes) ProtoMessage() {} func (x *SubscribeRes) ProtoReflect() protoreflect.Message { - mi := &file_msg_lake_proto_msgTypes[3] + mi := &file_proto_msg_lake_proto_msgTypes[3] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -278,7 +278,7 @@ func (x *SubscribeRes) ProtoReflect() protoreflect.Message { // Deprecated: Use SubscribeRes.ProtoReflect.Descriptor instead. func (*SubscribeRes) Descriptor() ([]byte, []int) { - return file_msg_lake_proto_rawDescGZIP(), []int{3} + return file_proto_msg_lake_proto_rawDescGZIP(), []int{3} } func (x *SubscribeRes) GetType() SubscribeResType { @@ -344,15 +344,16 @@ type MsgCapsule struct { sizeCache protoimpl.SizeCache unknownFields protoimpl.UnknownFields - Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` - Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` - Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` + Signature *Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` + Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` + IsEncrypted bool `protobuf:"varint,4,opt,name=is_encrypted,json=isEncrypted,proto3" json:"is_encrypted,omitempty"` } func (x *MsgCapsule) Reset() { *x = MsgCapsule{} if protoimpl.UnsafeEnabled { - mi := &file_msg_lake_proto_msgTypes[4] + mi := &file_proto_msg_lake_proto_msgTypes[4] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -365,7 +366,7 @@ func (x *MsgCapsule) String() string { func (*MsgCapsule) ProtoMessage() {} func (x *MsgCapsule) ProtoReflect() protoreflect.Message { - mi := &file_msg_lake_proto_msgTypes[4] + mi := &file_proto_msg_lake_proto_msgTypes[4] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -378,7 +379,7 @@ func (x *MsgCapsule) ProtoReflect() protoreflect.Message { // Deprecated: Use MsgCapsule.ProtoReflect.Descriptor instead. func (*MsgCapsule) Descriptor() ([]byte, []int) { - return file_msg_lake_proto_rawDescGZIP(), []int{4} + return file_proto_msg_lake_proto_rawDescGZIP(), []int{4} } func (x *MsgCapsule) GetData() []byte { @@ -402,6 +403,13 @@ func (x *MsgCapsule) GetTimestamp() int64 { return 0 } +func (x *MsgCapsule) GetIsEncrypted() bool { + if x != nil { + return x.IsEncrypted + } + return false +} + type Signature struct { state protoimpl.MessageState sizeCache protoimpl.SizeCache @@ -414,7 +422,7 @@ type Signature struct { func (x *Signature) Reset() { *x = Signature{} if protoimpl.UnsafeEnabled { - mi := &file_msg_lake_proto_msgTypes[5] + mi := &file_proto_msg_lake_proto_msgTypes[5] ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) ms.StoreMessageInfo(mi) } @@ -427,7 +435,7 @@ func (x *Signature) String() string { func (*Signature) ProtoMessage() {} func (x *Signature) ProtoReflect() protoreflect.Message { - mi := &file_msg_lake_proto_msgTypes[5] + mi := &file_proto_msg_lake_proto_msgTypes[5] if protoimpl.UnsafeEnabled && x != nil { ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) if ms.LoadMessageInfo() == nil { @@ -440,7 +448,7 @@ func (x *Signature) ProtoReflect() protoreflect.Message { // Deprecated: Use Signature.ProtoReflect.Descriptor instead. func (*Signature) Descriptor() ([]byte, []int) { - return file_msg_lake_proto_rawDescGZIP(), []int{5} + return file_proto_msg_lake_proto_rawDescGZIP(), []int{5} } func (x *Signature) GetPubKey() []byte { @@ -457,80 +465,83 @@ func (x *Signature) GetData() []byte { return nil } -var File_msg_lake_proto protoreflect.FileDescriptor - -var file_msg_lake_proto_rawDesc = []byte{ - 0x0a, 0x0e, 0x6d, 0x73, 0x67, 0x2d, 0x6c, 0x61, 0x6b, 0x65, 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, - 0x22, 0x55, 0x0a, 0x0a, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x71, 0x12, 0x19, - 0x0a, 0x08, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, - 0x52, 0x07, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x49, 0x64, 0x12, 0x2c, 0x0a, 0x0b, 0x6d, 0x73, 0x67, - 0x5f, 0x63, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0b, - 0x2e, 0x4d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x52, 0x0a, 0x6d, 0x73, 0x67, - 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x22, 0x37, 0x0a, 0x0a, 0x50, 0x75, 0x62, 0x6c, 0x69, - 0x73, 0x68, 0x52, 0x65, 0x73, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x5f, 0x69, - 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x49, 0x64, - 0x12, 0x0e, 0x0a, 0x02, 0x6f, 0x6b, 0x18, 0x02, 0x20, 0x01, 0x28, 0x08, 0x52, 0x02, 0x6f, 0x6b, - 0x22, 0x57, 0x0a, 0x0c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, - 0x12, 0x19, 0x0a, 0x08, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x09, 0x52, 0x07, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x49, 0x64, 0x12, 0x2c, 0x0a, 0x0b, 0x6d, - 0x73, 0x67, 0x5f, 0x63, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, - 0x32, 0x0b, 0x2e, 0x4d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x52, 0x0a, 0x6d, - 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x22, 0xbe, 0x01, 0x0a, 0x0c, 0x53, 0x75, - 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x12, 0x25, 0x0a, 0x04, 0x74, 0x79, - 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x11, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, - 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x54, 0x79, 0x70, 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, - 0x65, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0d, - 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x72, 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, - 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x72, 0x49, - 0x64, 0x12, 0x10, 0x0a, 0x02, 0x6f, 0x6b, 0x18, 0x04, 0x20, 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, - 0x02, 0x6f, 0x6b, 0x12, 0x2e, 0x0a, 0x0b, 0x6d, 0x73, 0x67, 0x5f, 0x63, 0x61, 0x70, 0x73, 0x75, - 0x6c, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x4d, 0x73, 0x67, 0x43, 0x61, - 0x70, 0x73, 0x75, 0x6c, 0x65, 0x48, 0x00, 0x52, 0x0a, 0x6d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, - 0x75, 0x6c, 0x65, 0x42, 0x05, 0x0a, 0x03, 0x72, 0x65, 0x73, 0x22, 0x68, 0x0a, 0x0a, 0x4d, 0x73, - 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, - 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x12, 0x28, 0x0a, 0x09, - 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, - 0x0a, 0x2e, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x52, 0x09, 0x73, 0x69, 0x67, - 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x12, 0x1c, 0x0a, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, - 0x61, 0x6d, 0x70, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, - 0x74, 0x61, 0x6d, 0x70, 0x22, 0x38, 0x0a, 0x09, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, - 0x65, 0x12, 0x17, 0x0a, 0x07, 0x70, 0x75, 0x62, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, - 0x28, 0x0c, 0x52, 0x06, 0x70, 0x75, 0x62, 0x4b, 0x65, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, - 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x2a, 0x70, - 0x0a, 0x10, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x54, 0x79, - 0x70, 0x65, 0x12, 0x22, 0x0a, 0x1e, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x42, 0x45, 0x5f, - 0x52, 0x45, 0x53, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, - 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, 0x12, 0x1a, 0x0a, 0x16, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, - 0x49, 0x42, 0x45, 0x5f, 0x52, 0x45, 0x53, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x41, 0x43, 0x4b, - 0x10, 0x01, 0x12, 0x1c, 0x0a, 0x18, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x42, 0x45, 0x5f, - 0x52, 0x45, 0x53, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x52, 0x45, 0x4c, 0x41, 0x59, 0x10, 0x02, - 0x32, 0x5b, 0x0a, 0x07, 0x4d, 0x73, 0x67, 0x4c, 0x61, 0x6b, 0x65, 0x12, 0x23, 0x0a, 0x07, 0x50, - 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x12, 0x0b, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, - 0x52, 0x65, 0x71, 0x1a, 0x0b, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x73, - 0x12, 0x2b, 0x0a, 0x09, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x12, 0x0d, 0x2e, - 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x1a, 0x0d, 0x2e, 0x53, - 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x30, 0x01, 0x42, 0x20, 0x5a, - 0x1e, 0x67, 0x69, 0x74, 0x68, 0x75, 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x68, 0x30, 0x6e, 0x39, - 0x2f, 0x6d, 0x73, 0x67, 0x2d, 0x6c, 0x61, 0x6b, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, - 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x33, +var File_proto_msg_lake_proto protoreflect.FileDescriptor + +var file_proto_msg_lake_proto_rawDesc = []byte{ + 0x0a, 0x14, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x2f, 0x6d, 0x73, 0x67, 0x2d, 0x6c, 0x61, 0x6b, 0x65, + 0x2e, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x22, 0x55, 0x0a, 0x0a, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, + 0x68, 0x52, 0x65, 0x71, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x5f, 0x69, 0x64, + 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x49, 0x64, 0x12, + 0x2c, 0x0a, 0x0b, 0x6d, 0x73, 0x67, 0x5f, 0x63, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x18, 0x02, + 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x4d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, + 0x65, 0x52, 0x0a, 0x6d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x22, 0x37, 0x0a, + 0x0a, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x73, 0x12, 0x19, 0x0a, 0x08, 0x74, + 0x6f, 0x70, 0x69, 0x63, 0x5f, 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, + 0x6f, 0x70, 0x69, 0x63, 0x49, 0x64, 0x12, 0x0e, 0x0a, 0x02, 0x6f, 0x6b, 0x18, 0x02, 0x20, 0x01, + 0x28, 0x08, 0x52, 0x02, 0x6f, 0x6b, 0x22, 0x57, 0x0a, 0x0c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, + 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x5f, + 0x69, 0x64, 0x18, 0x01, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, 0x6f, 0x70, 0x69, 0x63, 0x49, + 0x64, 0x12, 0x2c, 0x0a, 0x0b, 0x6d, 0x73, 0x67, 0x5f, 0x63, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0b, 0x2e, 0x4d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, + 0x75, 0x6c, 0x65, 0x52, 0x0a, 0x6d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x22, + 0xbe, 0x01, 0x0a, 0x0c, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, + 0x12, 0x25, 0x0a, 0x04, 0x74, 0x79, 0x70, 0x65, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0e, 0x32, 0x11, + 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x54, 0x79, 0x70, + 0x65, 0x52, 0x04, 0x74, 0x79, 0x70, 0x65, 0x12, 0x19, 0x0a, 0x08, 0x74, 0x6f, 0x70, 0x69, 0x63, + 0x5f, 0x69, 0x64, 0x18, 0x02, 0x20, 0x01, 0x28, 0x09, 0x52, 0x07, 0x74, 0x6f, 0x70, 0x69, 0x63, + 0x49, 0x64, 0x12, 0x23, 0x0a, 0x0d, 0x73, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x72, + 0x5f, 0x69, 0x64, 0x18, 0x03, 0x20, 0x01, 0x28, 0x09, 0x52, 0x0c, 0x73, 0x75, 0x62, 0x73, 0x63, + 0x72, 0x69, 0x62, 0x65, 0x72, 0x49, 0x64, 0x12, 0x10, 0x0a, 0x02, 0x6f, 0x6b, 0x18, 0x04, 0x20, + 0x01, 0x28, 0x08, 0x48, 0x00, 0x52, 0x02, 0x6f, 0x6b, 0x12, 0x2e, 0x0a, 0x0b, 0x6d, 0x73, 0x67, + 0x5f, 0x63, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x18, 0x05, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0b, + 0x2e, 0x4d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x48, 0x00, 0x52, 0x0a, 0x6d, + 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x42, 0x05, 0x0a, 0x03, 0x72, 0x65, 0x73, + 0x22, 0x8b, 0x01, 0x0a, 0x0a, 0x4d, 0x73, 0x67, 0x43, 0x61, 0x70, 0x73, 0x75, 0x6c, 0x65, 0x12, + 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x04, 0x64, + 0x61, 0x74, 0x61, 0x12, 0x28, 0x0a, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, + 0x18, 0x02, 0x20, 0x01, 0x28, 0x0b, 0x32, 0x0a, 0x2e, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, + 0x72, 0x65, 0x52, 0x09, 0x73, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x12, 0x1c, 0x0a, + 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x18, 0x03, 0x20, 0x01, 0x28, 0x03, + 0x52, 0x09, 0x74, 0x69, 0x6d, 0x65, 0x73, 0x74, 0x61, 0x6d, 0x70, 0x12, 0x21, 0x0a, 0x0c, 0x69, + 0x73, 0x5f, 0x65, 0x6e, 0x63, 0x72, 0x79, 0x70, 0x74, 0x65, 0x64, 0x18, 0x04, 0x20, 0x01, 0x28, + 0x08, 0x52, 0x0b, 0x69, 0x73, 0x45, 0x6e, 0x63, 0x72, 0x79, 0x70, 0x74, 0x65, 0x64, 0x22, 0x38, + 0x0a, 0x09, 0x53, 0x69, 0x67, 0x6e, 0x61, 0x74, 0x75, 0x72, 0x65, 0x12, 0x17, 0x0a, 0x07, 0x70, + 0x75, 0x62, 0x5f, 0x6b, 0x65, 0x79, 0x18, 0x01, 0x20, 0x01, 0x28, 0x0c, 0x52, 0x06, 0x70, 0x75, + 0x62, 0x4b, 0x65, 0x79, 0x12, 0x12, 0x0a, 0x04, 0x64, 0x61, 0x74, 0x61, 0x18, 0x02, 0x20, 0x01, + 0x28, 0x0c, 0x52, 0x04, 0x64, 0x61, 0x74, 0x61, 0x2a, 0x70, 0x0a, 0x10, 0x53, 0x75, 0x62, 0x73, + 0x63, 0x72, 0x69, 0x62, 0x65, 0x52, 0x65, 0x73, 0x54, 0x79, 0x70, 0x65, 0x12, 0x22, 0x0a, 0x1e, + 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x42, 0x45, 0x5f, 0x52, 0x45, 0x53, 0x5f, 0x54, 0x59, + 0x50, 0x45, 0x5f, 0x55, 0x4e, 0x53, 0x50, 0x45, 0x43, 0x49, 0x46, 0x49, 0x45, 0x44, 0x10, 0x00, + 0x12, 0x1a, 0x0a, 0x16, 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x42, 0x45, 0x5f, 0x52, 0x45, + 0x53, 0x5f, 0x54, 0x59, 0x50, 0x45, 0x5f, 0x41, 0x43, 0x4b, 0x10, 0x01, 0x12, 0x1c, 0x0a, 0x18, + 0x53, 0x55, 0x42, 0x53, 0x43, 0x52, 0x49, 0x42, 0x45, 0x5f, 0x52, 0x45, 0x53, 0x5f, 0x54, 0x59, + 0x50, 0x45, 0x5f, 0x52, 0x45, 0x4c, 0x41, 0x59, 0x10, 0x02, 0x32, 0x5b, 0x0a, 0x07, 0x4d, 0x73, + 0x67, 0x4c, 0x61, 0x6b, 0x65, 0x12, 0x23, 0x0a, 0x07, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, + 0x12, 0x0b, 0x2e, 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x71, 0x1a, 0x0b, 0x2e, + 0x50, 0x75, 0x62, 0x6c, 0x69, 0x73, 0x68, 0x52, 0x65, 0x73, 0x12, 0x2b, 0x0a, 0x09, 0x53, 0x75, + 0x62, 0x73, 0x63, 0x72, 0x69, 0x62, 0x65, 0x12, 0x0d, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, + 0x69, 0x62, 0x65, 0x52, 0x65, 0x71, 0x1a, 0x0d, 0x2e, 0x53, 0x75, 0x62, 0x73, 0x63, 0x72, 0x69, + 0x62, 0x65, 0x52, 0x65, 0x73, 0x30, 0x01, 0x42, 0x20, 0x5a, 0x1e, 0x67, 0x69, 0x74, 0x68, 0x75, + 0x62, 0x2e, 0x63, 0x6f, 0x6d, 0x2f, 0x68, 0x30, 0x6e, 0x39, 0x2f, 0x6d, 0x73, 0x67, 0x2d, 0x6c, + 0x61, 0x6b, 0x65, 0x2f, 0x70, 0x72, 0x6f, 0x74, 0x6f, 0x62, 0x06, 0x70, 0x72, 0x6f, 0x74, 0x6f, + 0x33, } var ( - file_msg_lake_proto_rawDescOnce sync.Once - file_msg_lake_proto_rawDescData = file_msg_lake_proto_rawDesc + file_proto_msg_lake_proto_rawDescOnce sync.Once + file_proto_msg_lake_proto_rawDescData = file_proto_msg_lake_proto_rawDesc ) -func file_msg_lake_proto_rawDescGZIP() []byte { - file_msg_lake_proto_rawDescOnce.Do(func() { - file_msg_lake_proto_rawDescData = protoimpl.X.CompressGZIP(file_msg_lake_proto_rawDescData) +func file_proto_msg_lake_proto_rawDescGZIP() []byte { + file_proto_msg_lake_proto_rawDescOnce.Do(func() { + file_proto_msg_lake_proto_rawDescData = protoimpl.X.CompressGZIP(file_proto_msg_lake_proto_rawDescData) }) - return file_msg_lake_proto_rawDescData + return file_proto_msg_lake_proto_rawDescData } -var file_msg_lake_proto_enumTypes = make([]protoimpl.EnumInfo, 1) -var file_msg_lake_proto_msgTypes = make([]protoimpl.MessageInfo, 6) -var file_msg_lake_proto_goTypes = []interface{}{ +var file_proto_msg_lake_proto_enumTypes = make([]protoimpl.EnumInfo, 1) +var file_proto_msg_lake_proto_msgTypes = make([]protoimpl.MessageInfo, 6) +var file_proto_msg_lake_proto_goTypes = []interface{}{ (SubscribeResType)(0), // 0: SubscribeResType (*PublishReq)(nil), // 1: PublishReq (*PublishRes)(nil), // 2: PublishRes @@ -539,7 +550,7 @@ var file_msg_lake_proto_goTypes = []interface{}{ (*MsgCapsule)(nil), // 5: MsgCapsule (*Signature)(nil), // 6: Signature } -var file_msg_lake_proto_depIdxs = []int32{ +var file_proto_msg_lake_proto_depIdxs = []int32{ 5, // 0: PublishReq.msg_capsule:type_name -> MsgCapsule 5, // 1: SubscribeReq.msg_capsule:type_name -> MsgCapsule 0, // 2: SubscribeRes.type:type_name -> SubscribeResType @@ -556,13 +567,13 @@ var file_msg_lake_proto_depIdxs = []int32{ 0, // [0:5] is the sub-list for field type_name } -func init() { file_msg_lake_proto_init() } -func file_msg_lake_proto_init() { - if File_msg_lake_proto != nil { +func init() { file_proto_msg_lake_proto_init() } +func file_proto_msg_lake_proto_init() { + if File_proto_msg_lake_proto != nil { return } if !protoimpl.UnsafeEnabled { - file_msg_lake_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { + file_proto_msg_lake_proto_msgTypes[0].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*PublishReq); i { case 0: return &v.state @@ -574,7 +585,7 @@ func file_msg_lake_proto_init() { return nil } } - file_msg_lake_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { + file_proto_msg_lake_proto_msgTypes[1].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*PublishRes); i { case 0: return &v.state @@ -586,7 +597,7 @@ func file_msg_lake_proto_init() { return nil } } - file_msg_lake_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { + file_proto_msg_lake_proto_msgTypes[2].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SubscribeReq); i { case 0: return &v.state @@ -598,7 +609,7 @@ func file_msg_lake_proto_init() { return nil } } - file_msg_lake_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { + file_proto_msg_lake_proto_msgTypes[3].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*SubscribeRes); i { case 0: return &v.state @@ -610,7 +621,7 @@ func file_msg_lake_proto_init() { return nil } } - file_msg_lake_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { + file_proto_msg_lake_proto_msgTypes[4].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*MsgCapsule); i { case 0: return &v.state @@ -622,7 +633,7 @@ func file_msg_lake_proto_init() { return nil } } - file_msg_lake_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { + file_proto_msg_lake_proto_msgTypes[5].Exporter = func(v interface{}, i int) interface{} { switch v := v.(*Signature); i { case 0: return &v.state @@ -635,7 +646,7 @@ func file_msg_lake_proto_init() { } } } - file_msg_lake_proto_msgTypes[3].OneofWrappers = []interface{}{ + file_proto_msg_lake_proto_msgTypes[3].OneofWrappers = []interface{}{ (*SubscribeRes_Ok)(nil), (*SubscribeRes_MsgCapsule)(nil), } @@ -643,19 +654,19 @@ func file_msg_lake_proto_init() { out := protoimpl.TypeBuilder{ File: protoimpl.DescBuilder{ GoPackagePath: reflect.TypeOf(x{}).PkgPath(), - RawDescriptor: file_msg_lake_proto_rawDesc, + RawDescriptor: file_proto_msg_lake_proto_rawDesc, NumEnums: 1, NumMessages: 6, NumExtensions: 0, NumServices: 1, }, - GoTypes: file_msg_lake_proto_goTypes, - DependencyIndexes: file_msg_lake_proto_depIdxs, - EnumInfos: file_msg_lake_proto_enumTypes, - MessageInfos: file_msg_lake_proto_msgTypes, + GoTypes: file_proto_msg_lake_proto_goTypes, + DependencyIndexes: file_proto_msg_lake_proto_depIdxs, + EnumInfos: file_proto_msg_lake_proto_enumTypes, + MessageInfos: file_proto_msg_lake_proto_msgTypes, }.Build() - File_msg_lake_proto = out.File - file_msg_lake_proto_rawDesc = nil - file_msg_lake_proto_goTypes = nil - file_msg_lake_proto_depIdxs = nil + File_proto_msg_lake_proto = out.File + file_proto_msg_lake_proto_rawDesc = nil + file_proto_msg_lake_proto_goTypes = nil + file_proto_msg_lake_proto_depIdxs = nil } diff --git a/proto/msg-lake_grpc.pb.go b/proto/msg-lake_grpc.pb.go index b0acd44..7fc1219 100644 --- a/proto/msg-lake_grpc.pb.go +++ b/proto/msg-lake_grpc.pb.go @@ -1,8 +1,8 @@ // Code generated by protoc-gen-go-grpc. DO NOT EDIT. // versions: // - protoc-gen-go-grpc v1.3.0 -// - protoc v4.25.0 -// source: msg-lake.proto +// - protoc v5.26.1 +// source: proto/msg-lake.proto package proto @@ -170,5 +170,5 @@ var MsgLake_ServiceDesc = grpc.ServiceDesc{ ServerStreams: true, }, }, - Metadata: "msg-lake.proto", + Metadata: "proto/msg-lake.proto", }