diff --git a/grpc_internal.pb.go b/grpc_internal.pb.go index 470c6a0..b0e4219 100644 --- a/grpc_internal.pb.go +++ b/grpc_internal.pb.go @@ -127,6 +127,154 @@ func (x *GetServerIdReply) GetVersion() string { return "" } +type GetTransientDataRequest struct { + state protoimpl.MessageState `protogen:"open.v1"` + RoomId string `protobuf:"bytes,1,opt,name=roomId,proto3" json:"roomId,omitempty"` + BackendUrls []string `protobuf:"bytes,2,rep,name=backendUrls,proto3" json:"backendUrls,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetTransientDataRequest) Reset() { + *x = GetTransientDataRequest{} + mi := &file_grpc_internal_proto_msgTypes[2] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetTransientDataRequest) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetTransientDataRequest) ProtoMessage() {} + +func (x *GetTransientDataRequest) ProtoReflect() protoreflect.Message { + mi := &file_grpc_internal_proto_msgTypes[2] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GetTransientDataRequest.ProtoReflect.Descriptor instead. +func (*GetTransientDataRequest) Descriptor() ([]byte, []int) { + return file_grpc_internal_proto_rawDescGZIP(), []int{2} +} + +func (x *GetTransientDataRequest) GetRoomId() string { + if x != nil { + return x.RoomId + } + return "" +} + +func (x *GetTransientDataRequest) GetBackendUrls() []string { + if x != nil { + return x.BackendUrls + } + return nil +} + +type GrpcTransientDataEntry struct { + state protoimpl.MessageState `protogen:"open.v1"` + Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` + Expires int64 `protobuf:"varint,2,opt,name=expires,proto3" json:"expires,omitempty"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GrpcTransientDataEntry) Reset() { + *x = GrpcTransientDataEntry{} + mi := &file_grpc_internal_proto_msgTypes[3] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GrpcTransientDataEntry) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GrpcTransientDataEntry) ProtoMessage() {} + +func (x *GrpcTransientDataEntry) ProtoReflect() protoreflect.Message { + mi := &file_grpc_internal_proto_msgTypes[3] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GrpcTransientDataEntry.ProtoReflect.Descriptor instead. +func (*GrpcTransientDataEntry) Descriptor() ([]byte, []int) { + return file_grpc_internal_proto_rawDescGZIP(), []int{3} +} + +func (x *GrpcTransientDataEntry) GetValue() []byte { + if x != nil { + return x.Value + } + return nil +} + +func (x *GrpcTransientDataEntry) GetExpires() int64 { + if x != nil { + return x.Expires + } + return 0 +} + +type GetTransientDataReply struct { + state protoimpl.MessageState `protogen:"open.v1"` + Entries map[string]*GrpcTransientDataEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"` + unknownFields protoimpl.UnknownFields + sizeCache protoimpl.SizeCache +} + +func (x *GetTransientDataReply) Reset() { + *x = GetTransientDataReply{} + mi := &file_grpc_internal_proto_msgTypes[4] + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + ms.StoreMessageInfo(mi) +} + +func (x *GetTransientDataReply) String() string { + return protoimpl.X.MessageStringOf(x) +} + +func (*GetTransientDataReply) ProtoMessage() {} + +func (x *GetTransientDataReply) ProtoReflect() protoreflect.Message { + mi := &file_grpc_internal_proto_msgTypes[4] + if x != nil { + ms := protoimpl.X.MessageStateOf(protoimpl.Pointer(x)) + if ms.LoadMessageInfo() == nil { + ms.StoreMessageInfo(mi) + } + return ms + } + return mi.MessageOf(x) +} + +// Deprecated: Use GetTransientDataReply.ProtoReflect.Descriptor instead. +func (*GetTransientDataReply) Descriptor() ([]byte, []int) { + return file_grpc_internal_proto_rawDescGZIP(), []int{4} +} + +func (x *GetTransientDataReply) GetEntries() map[string]*GrpcTransientDataEntry { + if x != nil { + return x.Entries + } + return nil +} + var File_grpc_internal_proto protoreflect.FileDescriptor const file_grpc_internal_proto_rawDesc = "" + @@ -135,9 +283,21 @@ const file_grpc_internal_proto_rawDesc = "" + "\x12GetServerIdRequest\"H\n" + "\x10GetServerIdReply\x12\x1a\n" + "\bserverId\x18\x01 \x01(\tR\bserverId\x12\x18\n" + - "\aversion\x18\x02 \x01(\tR\aversion2Z\n" + + "\aversion\x18\x02 \x01(\tR\aversion\"S\n" + + "\x17GetTransientDataRequest\x12\x16\n" + + "\x06roomId\x18\x01 \x01(\tR\x06roomId\x12 \n" + + "\vbackendUrls\x18\x02 \x03(\tR\vbackendUrls\"H\n" + + "\x16GrpcTransientDataEntry\x12\x14\n" + + "\x05value\x18\x01 \x01(\fR\x05value\x12\x18\n" + + "\aexpires\x18\x02 \x01(\x03R\aexpires\"\xbf\x01\n" + + "\x15GetTransientDataReply\x12G\n" + + "\aentries\x18\x01 \x03(\v2-.signaling.GetTransientDataReply.EntriesEntryR\aentries\x1a]\n" + + "\fEntriesEntry\x12\x10\n" + + "\x03key\x18\x01 \x01(\tR\x03key\x127\n" + + "\x05value\x18\x02 \x01(\v2!.signaling.GrpcTransientDataEntryR\x05value:\x028\x012\xb6\x01\n" + "\vRpcInternal\x12K\n" + - "\vGetServerId\x12\x1d.signaling.GetServerIdRequest\x1a\x1b.signaling.GetServerIdReply\"\x00B signaling.GetServerIdRequest - 1, // 1: signaling.RpcInternal.GetServerId:output_type -> signaling.GetServerIdReply - 1, // [1:2] is the sub-list for method output_type - 0, // [0:1] is the sub-list for method input_type - 0, // [0:0] is the sub-list for extension type_name - 0, // [0:0] is the sub-list for extension extendee - 0, // [0:0] is the sub-list for field type_name + 5, // 0: signaling.GetTransientDataReply.entries:type_name -> signaling.GetTransientDataReply.EntriesEntry + 3, // 1: signaling.GetTransientDataReply.EntriesEntry.value:type_name -> signaling.GrpcTransientDataEntry + 0, // 2: signaling.RpcInternal.GetServerId:input_type -> signaling.GetServerIdRequest + 2, // 3: signaling.RpcInternal.GetTransientData:input_type -> signaling.GetTransientDataRequest + 1, // 4: signaling.RpcInternal.GetServerId:output_type -> signaling.GetServerIdReply + 4, // 5: signaling.RpcInternal.GetTransientData:output_type -> signaling.GetTransientDataReply + 4, // [4:6] is the sub-list for method output_type + 2, // [2:4] is the sub-list for method input_type + 2, // [2:2] is the sub-list for extension type_name + 2, // [2:2] is the sub-list for extension extendee + 0, // [0:2] is the sub-list for field type_name } func init() { file_grpc_internal_proto_init() } @@ -177,7 +345,7 @@ func file_grpc_internal_proto_init() { GoPackagePath: reflect.TypeOf(x{}).PkgPath(), RawDescriptor: unsafe.Slice(unsafe.StringData(file_grpc_internal_proto_rawDesc), len(file_grpc_internal_proto_rawDesc)), NumEnums: 0, - NumMessages: 2, + NumMessages: 6, NumExtensions: 0, NumServices: 1, }, diff --git a/grpc_internal_grpc.pb.go b/grpc_internal_grpc.pb.go index 577ef0d..ace5174 100644 --- a/grpc_internal_grpc.pb.go +++ b/grpc_internal_grpc.pb.go @@ -37,7 +37,8 @@ import ( const _ = grpc.SupportPackageIsVersion9 const ( - RpcInternal_GetServerId_FullMethodName = "/signaling.RpcInternal/GetServerId" + RpcInternal_GetServerId_FullMethodName = "/signaling.RpcInternal/GetServerId" + RpcInternal_GetTransientData_FullMethodName = "/signaling.RpcInternal/GetTransientData" ) // RpcInternalClient is the client API for RpcInternal service. @@ -45,6 +46,7 @@ const ( // 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 RpcInternalClient interface { GetServerId(ctx context.Context, in *GetServerIdRequest, opts ...grpc.CallOption) (*GetServerIdReply, error) + GetTransientData(ctx context.Context, in *GetTransientDataRequest, opts ...grpc.CallOption) (*GetTransientDataReply, error) } type rpcInternalClient struct { @@ -65,11 +67,22 @@ func (c *rpcInternalClient) GetServerId(ctx context.Context, in *GetServerIdRequ return out, nil } +func (c *rpcInternalClient) GetTransientData(ctx context.Context, in *GetTransientDataRequest, opts ...grpc.CallOption) (*GetTransientDataReply, error) { + cOpts := append([]grpc.CallOption{grpc.StaticMethod()}, opts...) + out := new(GetTransientDataReply) + err := c.cc.Invoke(ctx, RpcInternal_GetTransientData_FullMethodName, in, out, cOpts...) + if err != nil { + return nil, err + } + return out, nil +} + // RpcInternalServer is the server API for RpcInternal service. // All implementations must embed UnimplementedRpcInternalServer // for forward compatibility. type RpcInternalServer interface { GetServerId(context.Context, *GetServerIdRequest) (*GetServerIdReply, error) + GetTransientData(context.Context, *GetTransientDataRequest) (*GetTransientDataReply, error) mustEmbedUnimplementedRpcInternalServer() } @@ -83,6 +96,9 @@ type UnimplementedRpcInternalServer struct{} func (UnimplementedRpcInternalServer) GetServerId(context.Context, *GetServerIdRequest) (*GetServerIdReply, error) { return nil, status.Errorf(codes.Unimplemented, "method GetServerId not implemented") } +func (UnimplementedRpcInternalServer) GetTransientData(context.Context, *GetTransientDataRequest) (*GetTransientDataReply, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetTransientData not implemented") +} func (UnimplementedRpcInternalServer) mustEmbedUnimplementedRpcInternalServer() {} func (UnimplementedRpcInternalServer) testEmbeddedByValue() {} @@ -122,6 +138,24 @@ func _RpcInternal_GetServerId_Handler(srv interface{}, ctx context.Context, dec return interceptor(ctx, in, info, handler) } +func _RpcInternal_GetTransientData_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetTransientDataRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(RpcInternalServer).GetTransientData(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: RpcInternal_GetTransientData_FullMethodName, + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(RpcInternalServer).GetTransientData(ctx, req.(*GetTransientDataRequest)) + } + return interceptor(ctx, in, info, handler) +} + // RpcInternal_ServiceDesc is the grpc.ServiceDesc for RpcInternal service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -133,6 +167,10 @@ var RpcInternal_ServiceDesc = grpc.ServiceDesc{ MethodName: "GetServerId", Handler: _RpcInternal_GetServerId_Handler, }, + { + MethodName: "GetTransientData", + Handler: _RpcInternal_GetTransientData_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "grpc_internal.proto",