Versions in this module Expand all Collapse all v0 v0.2.0 Jul 12, 2019 v0.1.0 Jan 30, 2019 Changes in this version + func RegisterStreamerHandler(s server.Server, hdlr StreamerHandler, opts ...server.HandlerOption) + func RegisterStreamerServer(s *grpc.Server, srv StreamerServer) + type Request struct + Count int64 + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetCount() int64 + func (m *Request) Reset() + func (m *Request) String() string + type Response struct + Count int64 + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) GetCount() int64 + func (m *Response) Reset() + func (m *Response) String() string + type StreamerClient interface + ServerStream func(ctx context.Context, in *Request, opts ...grpc.CallOption) (Streamer_ServerStreamClient, error) + Stream func(ctx context.Context, opts ...grpc.CallOption) (Streamer_StreamClient, error) + func NewStreamerClient(cc *grpc.ClientConn) StreamerClient + type StreamerHandler interface + ServerStream func(context.Context, *Request, Streamer_ServerStreamStream) error + Stream func(context.Context, Streamer_StreamStream) error + type StreamerServer interface + ServerStream func(*Request, Streamer_ServerStreamServer) error + Stream func(Streamer_StreamServer) error + type StreamerService interface + ServerStream func(ctx context.Context, in *Request, opts ...client.CallOption) (Streamer_ServerStreamService, error) + Stream func(ctx context.Context, opts ...client.CallOption) (Streamer_StreamService, error) + func NewStreamerService(serviceName string, c client.Client) StreamerService + type Streamer_ServerStreamClient interface + Recv func() (*Response, error) + type Streamer_ServerStreamServer interface + Send func(*Response) error + type Streamer_ServerStreamService interface + Close func() error + Recv func() (*Response, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Streamer_ServerStreamStream interface + Close func() error + RecvMsg func(interface{}) error + Send func(*Response) error + SendMsg func(interface{}) error + type Streamer_StreamClient interface + Recv func() (*Response, error) + Send func(*Request) error + type Streamer_StreamServer interface + Recv func() (*Request, error) + Send func(*Response) error + type Streamer_StreamService interface + Close func() error + Recv func() (*Response, error) + RecvMsg func(interface{}) error + Send func(*Request) error + SendMsg func(interface{}) error + type Streamer_StreamStream interface + Close func() error + Recv func() (*Request, error) + RecvMsg func(interface{}) error + Send func(*Response) error + SendMsg func(interface{}) error
Go to main page