Versions in this module Expand all Collapse all v0 v0.2.0 Nov 30, 2022 Changes in this version + func Serve(stream RgrpcService_OpenRgrpcClient, handlers HandlerMap, ...) error + type Client struct + Peer *peer.Peer + RequestHeaders metadata.MD + func NewClient(stream RgrpcService_OpenRgrpcServer) *Client + func (c *Client) Close() + func (c *Client) Context() context.Context + func (c *Client) Done() <-chan struct{} + func (c *Client) Err() error + func (c *Client) Invoke(ctx context.Context, methodName string, req, resp interface{}, ...) error + func (c *Client) IsDone() bool + func (c *Client) NewStream(ctx context.Context, desc *grpc.StreamDesc, methodName string, ...) (grpc.ClientStream, error) v0.1.0 May 23, 2022 Changes in this version + var File_rgrpc_proto protoreflect.FileDescriptor + var RgrpcService_ServiceDesc = grpc.ServiceDesc + func RegisterRgrpcServiceServer(s grpc.ServiceRegistrar, srv RgrpcServiceServer) + func ServeChannel(stream RgrpcService_OpenRgrpcClient, handlers HandlerMap) error + type ClientChannel struct + Peer *peer.Peer + RequestHeaders metadata.MD + func NewClientChannel(stream RgrpcService_OpenRgrpcServer) *ClientChannel + func (c *ClientChannel) Close() + func (c *ClientChannel) Context() context.Context + func (c *ClientChannel) Done() <-chan struct{} + func (c *ClientChannel) Err() error + func (c *ClientChannel) Invoke(ctx context.Context, methodName string, req, resp interface{}, ...) error + func (c *ClientChannel) IsDone() bool + func (c *ClientChannel) NewStream(ctx context.Context, desc *grpc.StreamDesc, methodName string, ...) (grpc.ClientStream, error) + type ClientToServer struct + Frame isClientToServer_Frame + StreamId int64 + func (*ClientToServer) Descriptor() ([]byte, []int) + func (*ClientToServer) ProtoMessage() + func (m *ClientToServer) GetFrame() isClientToServer_Frame + func (x *ClientToServer) GetCancel() *empty.Empty + func (x *ClientToServer) GetHalfClose() *empty.Empty + func (x *ClientToServer) GetMoreRequestData() []byte + func (x *ClientToServer) GetNewStream() *NewStream + func (x *ClientToServer) GetRequestMessage() *MessageData + func (x *ClientToServer) GetStreamId() int64 + func (x *ClientToServer) ProtoReflect() protoreflect.Message + func (x *ClientToServer) Reset() + func (x *ClientToServer) String() string + type ClientToServer_Cancel struct + Cancel *empty.Empty + type ClientToServer_HalfClose struct + HalfClose *empty.Empty + type ClientToServer_MoreRequestData struct + MoreRequestData []byte + type ClientToServer_NewStream struct + NewStream *NewStream + type ClientToServer_RequestMessage struct + RequestMessage *MessageData + type CloseStream struct + ResponseTrailers *Metadata + Status *status.Status + func (*CloseStream) Descriptor() ([]byte, []int) + func (*CloseStream) ProtoMessage() + func (x *CloseStream) GetResponseTrailers() *Metadata + func (x *CloseStream) GetStatus() *status.Status + func (x *CloseStream) ProtoReflect() protoreflect.Message + func (x *CloseStream) Reset() + func (x *CloseStream) String() string + type HandlerMap map[string]*serviceInfo + func (m HandlerMap) GetServiceInfo() map[string]grpc.ServiceInfo + func (m HandlerMap) RegisterService(desc *grpc.ServiceDesc, ss interface{}) + type MessageData struct + Data []byte + Size int32 + func (*MessageData) Descriptor() ([]byte, []int) + func (*MessageData) ProtoMessage() + func (x *MessageData) GetData() []byte + func (x *MessageData) GetSize() int32 + func (x *MessageData) ProtoReflect() protoreflect.Message + func (x *MessageData) Reset() + func (x *MessageData) String() string + type Metadata struct + Md map[string]*Metadata_Values + func (*Metadata) Descriptor() ([]byte, []int) + func (*Metadata) ProtoMessage() + func (x *Metadata) GetMd() map[string]*Metadata_Values + func (x *Metadata) ProtoReflect() protoreflect.Message + func (x *Metadata) Reset() + func (x *Metadata) String() string + type Metadata_Values struct + Val []string + func (*Metadata_Values) Descriptor() ([]byte, []int) + func (*Metadata_Values) ProtoMessage() + func (x *Metadata_Values) GetVal() []string + func (x *Metadata_Values) ProtoReflect() protoreflect.Message + func (x *Metadata_Values) Reset() + func (x *Metadata_Values) String() string + type NewStream struct + MethodName string + RequestHeaders *Metadata + func (*NewStream) Descriptor() ([]byte, []int) + func (*NewStream) ProtoMessage() + func (x *NewStream) GetMethodName() string + func (x *NewStream) GetRequestHeaders() *Metadata + func (x *NewStream) ProtoReflect() protoreflect.Message + func (x *NewStream) Reset() + func (x *NewStream) String() string + type RgrpcServiceClient interface + OpenRgrpc func(ctx context.Context, opts ...grpc.CallOption) (RgrpcService_OpenRgrpcClient, error) + func NewRgrpcServiceClient(cc grpc.ClientConnInterface) RgrpcServiceClient + type RgrpcServiceServer interface + OpenRgrpc func(RgrpcService_OpenRgrpcServer) error + type RgrpcService_OpenRgrpcClient interface + Recv func() (*ClientToServer, error) + Send func(*ServerToClient) error + type RgrpcService_OpenRgrpcServer interface + Recv func() (*ServerToClient, error) + Send func(*ClientToServer) error + type ServerChannel struct + type ServerToClient struct + Frame isServerToClient_Frame + StreamId int64 + func (*ServerToClient) Descriptor() ([]byte, []int) + func (*ServerToClient) ProtoMessage() + func (m *ServerToClient) GetFrame() isServerToClient_Frame + func (x *ServerToClient) GetCloseStream() *CloseStream + func (x *ServerToClient) GetMoreResponseData() []byte + func (x *ServerToClient) GetResponseHeaders() *Metadata + func (x *ServerToClient) GetResponseMessage() *MessageData + func (x *ServerToClient) GetStreamId() int64 + func (x *ServerToClient) ProtoReflect() protoreflect.Message + func (x *ServerToClient) Reset() + func (x *ServerToClient) String() string + type ServerToClient_CloseStream struct + CloseStream *CloseStream + type ServerToClient_MoreResponseData struct + MoreResponseData []byte + type ServerToClient_ResponseHeaders struct + ResponseHeaders *Metadata + type ServerToClient_ResponseMessage struct + ResponseMessage *MessageData + type UnimplementedRgrpcServiceServer struct + func (UnimplementedRgrpcServiceServer) OpenRgrpc(RgrpcService_OpenRgrpcServer) error + type UnsafeRgrpcServiceServer interface