Versions in this module Expand all Collapse all v1 v1.7.1 Jul 17, 2020 Changes in this version + type BidiStream struct + func (s *BidiStream) CloseSend() error + func (s *BidiStream) Context() context.Context + func (s *BidiStream) Header() (metadata.MD, error) + func (s *BidiStream) RecvMsg() (proto.Message, error) + func (s *BidiStream) SendMsg(m proto.Message) error + func (s *BidiStream) Trailer() metadata.MD + type Channel interface + Invoke func(ctx context.Context, method string, args, reply interface{}, ...) error + NewStream func(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error) + type ClientStream struct + func (s *ClientStream) CloseAndReceive() (proto.Message, error) + func (s *ClientStream) Context() context.Context + func (s *ClientStream) Header() (metadata.MD, error) + func (s *ClientStream) SendMsg(m proto.Message) error + func (s *ClientStream) Trailer() metadata.MD + type ServerStream struct + func (s *ServerStream) Context() context.Context + func (s *ServerStream) Header() (metadata.MD, error) + func (s *ServerStream) RecvMsg() (proto.Message, error) + func (s *ServerStream) Trailer() metadata.MD + type Stub struct + func NewStub(channel Channel) Stub + func NewStubWithMessageFactory(channel Channel, mf *dynamic.MessageFactory) Stub + func (s Stub) InvokeRpc(ctx context.Context, method *desc.MethodDescriptor, request proto.Message, ...) (proto.Message, error) + func (s Stub) InvokeRpcBidiStream(ctx context.Context, method *desc.MethodDescriptor, opts ...grpc.CallOption) (*BidiStream, error) + func (s Stub) InvokeRpcClientStream(ctx context.Context, method *desc.MethodDescriptor, opts ...grpc.CallOption) (*ClientStream, error) + func (s Stub) InvokeRpcServerStream(ctx context.Context, method *desc.MethodDescriptor, request proto.Message, ...) (*ServerStream, error)
Go to main page