Documentation ¶
Index ¶
- Variables
- func RegisterPostFileServer(s grpc.ServiceRegistrar, srv PostFileServer)
- func RegisterReceiveContentServiceServer(s grpc.ServiceRegistrar, srv ReceiveContentServiceServer)
- func RegisterSendContentServiceServer(s grpc.ServiceRegistrar, srv SendContentServiceServer)
- type PostFileClient
- type PostFileServer
- type PostFile_PostFileRPCClient
- type PostFile_PostFileRPCServer
- type ReceiveContentRequest
- func (*ReceiveContentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReceiveContentRequest) GetMessage() string
- func (*ReceiveContentRequest) ProtoMessage()
- func (x *ReceiveContentRequest) ProtoReflect() protoreflect.Message
- func (x *ReceiveContentRequest) Reset()
- func (x *ReceiveContentRequest) String() string
- type ReceiveContentResponse
- func (*ReceiveContentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReceiveContentResponse) GetKey() string
- func (x *ReceiveContentResponse) GetObject() string
- func (x *ReceiveContentResponse) GetRoom() string
- func (x *ReceiveContentResponse) GetValue() string
- func (*ReceiveContentResponse) ProtoMessage()
- func (x *ReceiveContentResponse) ProtoReflect() protoreflect.Message
- func (x *ReceiveContentResponse) Reset()
- func (x *ReceiveContentResponse) String() string
- type ReceiveContentServiceClient
- type ReceiveContentServiceServer
- type RequestPostFile
- func (*RequestPostFile) Descriptor() ([]byte, []int)deprecated
- func (x *RequestPostFile) GetData() []byte
- func (x *RequestPostFile) GetName() string
- func (m *RequestPostFile) GetValue() isRequestPostFile_Value
- func (*RequestPostFile) ProtoMessage()
- func (x *RequestPostFile) ProtoReflect() protoreflect.Message
- func (x *RequestPostFile) Reset()
- func (x *RequestPostFile) String() string
- type RequestPostFile_Data
- type RequestPostFile_Name
- type ResponsePostFile
- type SendContentRequest
- func (*SendContentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SendContentRequest) GetKey() string
- func (x *SendContentRequest) GetObject() string
- func (x *SendContentRequest) GetRoom() string
- func (x *SendContentRequest) GetValue() string
- func (*SendContentRequest) ProtoMessage()
- func (x *SendContentRequest) ProtoReflect() protoreflect.Message
- func (x *SendContentRequest) Reset()
- func (x *SendContentRequest) String() string
- type SendContentResponse
- func (*SendContentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SendContentResponse) GetMessage() string
- func (*SendContentResponse) ProtoMessage()
- func (x *SendContentResponse) ProtoReflect() protoreflect.Message
- func (x *SendContentResponse) Reset()
- func (x *SendContentResponse) String() string
- type SendContentServiceClient
- type SendContentServiceServer
- type UnimplementedPostFileServer
- type UnimplementedReceiveContentServiceServer
- type UnimplementedSendContentServiceServer
- type UnsafePostFileServer
- type UnsafeReceiveContentServiceServer
- type UnsafeSendContentServiceServer
Constants ¶
This section is empty.
Variables ¶
var File_app_commonpb_common_proto protoreflect.FileDescriptor
var PostFile_ServiceDesc = grpc.ServiceDesc{ ServiceName: "commonpb.PostFile", HandlerType: (*PostFileServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "PostFileRPC", Handler: _PostFile_PostFileRPC_Handler, ClientStreams: true, }, }, Metadata: "app/commonpb/common.proto", }
PostFile_ServiceDesc is the grpc.ServiceDesc for PostFile service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ReceiveContentService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "commonpb.ReceiveContentService", HandlerType: (*ReceiveContentServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "ReceiveContentRPC", Handler: _ReceiveContentService_ReceiveContentRPC_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "app/commonpb/common.proto", }
ReceiveContentService_ServiceDesc is the grpc.ServiceDesc for ReceiveContentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SendContentService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "commonpb.SendContentService", HandlerType: (*SendContentServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SendContentRPC", Handler: _SendContentService_SendContentRPC_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "app/commonpb/common.proto", }
SendContentService_ServiceDesc is the grpc.ServiceDesc for SendContentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterPostFileServer ¶
func RegisterPostFileServer(s grpc.ServiceRegistrar, srv PostFileServer)
func RegisterReceiveContentServiceServer ¶
func RegisterReceiveContentServiceServer(s grpc.ServiceRegistrar, srv ReceiveContentServiceServer)
func RegisterSendContentServiceServer ¶
func RegisterSendContentServiceServer(s grpc.ServiceRegistrar, srv SendContentServiceServer)
Types ¶
type PostFileClient ¶
type PostFileClient interface {
PostFileRPC(ctx context.Context, opts ...grpc.CallOption) (PostFile_PostFileRPCClient, error)
}
PostFileClient is the client API for PostFile 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.
func NewPostFileClient ¶
func NewPostFileClient(cc grpc.ClientConnInterface) PostFileClient
type PostFileServer ¶
type PostFileServer interface { PostFileRPC(PostFile_PostFileRPCServer) error // contains filtered or unexported methods }
PostFileServer is the server API for PostFile service. All implementations must embed UnimplementedPostFileServer for forward compatibility
type PostFile_PostFileRPCClient ¶
type PostFile_PostFileRPCClient interface { Send(*RequestPostFile) error CloseAndRecv() (*ResponsePostFile, error) grpc.ClientStream }
type PostFile_PostFileRPCServer ¶
type PostFile_PostFileRPCServer interface { SendAndClose(*ResponsePostFile) error Recv() (*RequestPostFile, error) grpc.ServerStream }
type ReceiveContentRequest ¶
type ReceiveContentRequest struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ReceiveContentRequest) Descriptor
deprecated
func (*ReceiveContentRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveContentRequest.ProtoReflect.Descriptor instead.
func (*ReceiveContentRequest) GetMessage ¶
func (x *ReceiveContentRequest) GetMessage() string
func (*ReceiveContentRequest) ProtoMessage ¶
func (*ReceiveContentRequest) ProtoMessage()
func (*ReceiveContentRequest) ProtoReflect ¶
func (x *ReceiveContentRequest) ProtoReflect() protoreflect.Message
func (*ReceiveContentRequest) Reset ¶
func (x *ReceiveContentRequest) Reset()
func (*ReceiveContentRequest) String ¶
func (x *ReceiveContentRequest) String() string
type ReceiveContentResponse ¶
type ReceiveContentResponse struct { Room string `protobuf:"bytes,1,opt,name=Room,proto3" json:"Room,omitempty"` Object string `protobuf:"bytes,2,opt,name=Object,proto3" json:"Object,omitempty"` Key string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"` Value string `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"` // contains filtered or unexported fields }
func (*ReceiveContentResponse) Descriptor
deprecated
func (*ReceiveContentResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReceiveContentResponse.ProtoReflect.Descriptor instead.
func (*ReceiveContentResponse) GetKey ¶
func (x *ReceiveContentResponse) GetKey() string
func (*ReceiveContentResponse) GetObject ¶
func (x *ReceiveContentResponse) GetObject() string
func (*ReceiveContentResponse) GetRoom ¶
func (x *ReceiveContentResponse) GetRoom() string
func (*ReceiveContentResponse) GetValue ¶
func (x *ReceiveContentResponse) GetValue() string
func (*ReceiveContentResponse) ProtoMessage ¶
func (*ReceiveContentResponse) ProtoMessage()
func (*ReceiveContentResponse) ProtoReflect ¶
func (x *ReceiveContentResponse) ProtoReflect() protoreflect.Message
func (*ReceiveContentResponse) Reset ¶
func (x *ReceiveContentResponse) Reset()
func (*ReceiveContentResponse) String ¶
func (x *ReceiveContentResponse) String() string
type ReceiveContentServiceClient ¶
type ReceiveContentServiceClient interface {
ReceiveContentRPC(ctx context.Context, in *ReceiveContentRequest, opts ...grpc.CallOption) (*ReceiveContentResponse, error)
}
ReceiveContentServiceClient is the client API for ReceiveContentService 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.
func NewReceiveContentServiceClient ¶
func NewReceiveContentServiceClient(cc grpc.ClientConnInterface) ReceiveContentServiceClient
type ReceiveContentServiceServer ¶
type ReceiveContentServiceServer interface { ReceiveContentRPC(context.Context, *ReceiveContentRequest) (*ReceiveContentResponse, error) // contains filtered or unexported methods }
ReceiveContentServiceServer is the server API for ReceiveContentService service. All implementations must embed UnimplementedReceiveContentServiceServer for forward compatibility
type RequestPostFile ¶
type RequestPostFile struct { // Types that are assignable to Value: // *RequestPostFile_Data // *RequestPostFile_Name Value isRequestPostFile_Value `protobuf_oneof:"value"` // contains filtered or unexported fields }
func (*RequestPostFile) Descriptor
deprecated
func (*RequestPostFile) Descriptor() ([]byte, []int)
Deprecated: Use RequestPostFile.ProtoReflect.Descriptor instead.
func (*RequestPostFile) GetData ¶
func (x *RequestPostFile) GetData() []byte
func (*RequestPostFile) GetName ¶
func (x *RequestPostFile) GetName() string
func (*RequestPostFile) GetValue ¶
func (m *RequestPostFile) GetValue() isRequestPostFile_Value
func (*RequestPostFile) ProtoMessage ¶
func (*RequestPostFile) ProtoMessage()
func (*RequestPostFile) ProtoReflect ¶
func (x *RequestPostFile) ProtoReflect() protoreflect.Message
func (*RequestPostFile) Reset ¶
func (x *RequestPostFile) Reset()
func (*RequestPostFile) String ¶
func (x *RequestPostFile) String() string
type RequestPostFile_Data ¶
type RequestPostFile_Data struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3,oneof"`
}
type RequestPostFile_Name ¶
type RequestPostFile_Name struct {
Name string `protobuf:"bytes,2,opt,name=name,proto3,oneof"`
}
type ResponsePostFile ¶
type ResponsePostFile struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*ResponsePostFile) Descriptor
deprecated
func (*ResponsePostFile) Descriptor() ([]byte, []int)
Deprecated: Use ResponsePostFile.ProtoReflect.Descriptor instead.
func (*ResponsePostFile) GetMessage ¶
func (x *ResponsePostFile) GetMessage() string
func (*ResponsePostFile) ProtoMessage ¶
func (*ResponsePostFile) ProtoMessage()
func (*ResponsePostFile) ProtoReflect ¶
func (x *ResponsePostFile) ProtoReflect() protoreflect.Message
func (*ResponsePostFile) Reset ¶
func (x *ResponsePostFile) Reset()
func (*ResponsePostFile) String ¶
func (x *ResponsePostFile) String() string
type SendContentRequest ¶
type SendContentRequest struct { Room string `protobuf:"bytes,1,opt,name=Room,proto3" json:"Room,omitempty"` Object string `protobuf:"bytes,2,opt,name=Object,proto3" json:"Object,omitempty"` Key string `protobuf:"bytes,3,opt,name=Key,proto3" json:"Key,omitempty"` Value string `protobuf:"bytes,4,opt,name=Value,proto3" json:"Value,omitempty"` // contains filtered or unexported fields }
func (*SendContentRequest) Descriptor
deprecated
func (*SendContentRequest) Descriptor() ([]byte, []int)
Deprecated: Use SendContentRequest.ProtoReflect.Descriptor instead.
func (*SendContentRequest) GetKey ¶
func (x *SendContentRequest) GetKey() string
func (*SendContentRequest) GetObject ¶
func (x *SendContentRequest) GetObject() string
func (*SendContentRequest) GetRoom ¶
func (x *SendContentRequest) GetRoom() string
func (*SendContentRequest) GetValue ¶
func (x *SendContentRequest) GetValue() string
func (*SendContentRequest) ProtoMessage ¶
func (*SendContentRequest) ProtoMessage()
func (*SendContentRequest) ProtoReflect ¶
func (x *SendContentRequest) ProtoReflect() protoreflect.Message
func (*SendContentRequest) Reset ¶
func (x *SendContentRequest) Reset()
func (*SendContentRequest) String ¶
func (x *SendContentRequest) String() string
type SendContentResponse ¶
type SendContentResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*SendContentResponse) Descriptor
deprecated
func (*SendContentResponse) Descriptor() ([]byte, []int)
Deprecated: Use SendContentResponse.ProtoReflect.Descriptor instead.
func (*SendContentResponse) GetMessage ¶
func (x *SendContentResponse) GetMessage() string
func (*SendContentResponse) ProtoMessage ¶
func (*SendContentResponse) ProtoMessage()
func (*SendContentResponse) ProtoReflect ¶
func (x *SendContentResponse) ProtoReflect() protoreflect.Message
func (*SendContentResponse) Reset ¶
func (x *SendContentResponse) Reset()
func (*SendContentResponse) String ¶
func (x *SendContentResponse) String() string
type SendContentServiceClient ¶
type SendContentServiceClient interface {
SendContentRPC(ctx context.Context, in *SendContentRequest, opts ...grpc.CallOption) (*SendContentResponse, error)
}
SendContentServiceClient is the client API for SendContentService 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.
func NewSendContentServiceClient ¶
func NewSendContentServiceClient(cc grpc.ClientConnInterface) SendContentServiceClient
type SendContentServiceServer ¶
type SendContentServiceServer interface { SendContentRPC(context.Context, *SendContentRequest) (*SendContentResponse, error) // contains filtered or unexported methods }
SendContentServiceServer is the server API for SendContentService service. All implementations must embed UnimplementedSendContentServiceServer for forward compatibility
type UnimplementedPostFileServer ¶
type UnimplementedPostFileServer struct { }
UnimplementedPostFileServer must be embedded to have forward compatible implementations.
func (UnimplementedPostFileServer) PostFileRPC ¶
func (UnimplementedPostFileServer) PostFileRPC(PostFile_PostFileRPCServer) error
type UnimplementedReceiveContentServiceServer ¶
type UnimplementedReceiveContentServiceServer struct { }
UnimplementedReceiveContentServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedReceiveContentServiceServer) ReceiveContentRPC ¶
func (UnimplementedReceiveContentServiceServer) ReceiveContentRPC(context.Context, *ReceiveContentRequest) (*ReceiveContentResponse, error)
type UnimplementedSendContentServiceServer ¶
type UnimplementedSendContentServiceServer struct { }
UnimplementedSendContentServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedSendContentServiceServer) SendContentRPC ¶
func (UnimplementedSendContentServiceServer) SendContentRPC(context.Context, *SendContentRequest) (*SendContentResponse, error)
type UnsafePostFileServer ¶
type UnsafePostFileServer interface {
// contains filtered or unexported methods
}
UnsafePostFileServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PostFileServer will result in compilation errors.
type UnsafeReceiveContentServiceServer ¶
type UnsafeReceiveContentServiceServer interface {
// contains filtered or unexported methods
}
UnsafeReceiveContentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReceiveContentServiceServer will result in compilation errors.
type UnsafeSendContentServiceServer ¶
type UnsafeSendContentServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSendContentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SendContentServiceServer will result in compilation errors.