Documentation
¶
Index ¶
- func ClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, ...) error
- func ClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
- func ServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})
- func ServerServe(s *grpc.Server, lis net.Listener) error
- func WrapClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, ...) error
- func WrapClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)
- func WrapServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})
- func WrapServerServe(s *grpc.Server, lis net.Listener) error
- type ClientStreamWrapper
- func (w *ClientStreamWrapper) CloseSend() error
- func (w *ClientStreamWrapper) Context() context.Context
- func (w *ClientStreamWrapper) Header() (metadata.MD, error)
- func (w *ClientStreamWrapper) RecvMsg(m interface{}) error
- func (w *ClientStreamWrapper) SendMsg(m interface{}) error
- func (w *ClientStreamWrapper) Trailer() metadata.MD
- type StreamHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClientConnInvoke ¶
func ClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error
func ClientConnNewStream ¶
func ClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
func ServerRegisterService ¶
func ServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})
func WrapClientConnInvoke ¶
func WrapClientConnInvoke(cc *grpc.ClientConn, ctx context.Context, method string, args, reply interface{}, opts ...grpc.CallOption) error
func WrapClientConnNewStream ¶
func WrapClientConnNewStream(cc *grpc.ClientConn, ctx context.Context, desc *grpc.StreamDesc, method string, opts ...grpc.CallOption) (grpc.ClientStream, error)
func WrapServerRegisterService ¶
func WrapServerRegisterService(s *grpc.Server, sd *grpc.ServiceDesc, ss interface{})
Types ¶
type ClientStreamWrapper ¶
type ClientStreamWrapper struct {
// contains filtered or unexported fields
}
func (*ClientStreamWrapper) CloseSend ¶
func (w *ClientStreamWrapper) CloseSend() error
func (*ClientStreamWrapper) Context ¶
func (w *ClientStreamWrapper) Context() context.Context
func (*ClientStreamWrapper) RecvMsg ¶
func (w *ClientStreamWrapper) RecvMsg(m interface{}) error
func (*ClientStreamWrapper) SendMsg ¶
func (w *ClientStreamWrapper) SendMsg(m interface{}) error
func (*ClientStreamWrapper) Trailer ¶
func (w *ClientStreamWrapper) Trailer() metadata.MD
type StreamHandler ¶
type StreamHandler func(srv interface{}, stream grpc.ServerStream) error
Source Files
Click to show internal directories.
Click to hide internal directories.