Versions in this module Expand all Collapse all v0 v0.0.2 Mar 14, 2020 Changes in this version + func RegisterStreamsServer(s *grpc.Server, srv StreamsServer) + type Reply struct + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Reply) Descriptor() ([]byte, []int) + func (*Reply) ProtoMessage() + func (m *Reply) GetMsg() string + func (m *Reply) Reset() + func (m *Reply) String() string + func (m *Reply) XXX_DiscardUnknown() + func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Reply) XXX_Merge(src proto.Message) + func (m *Reply) XXX_Size() int + func (m *Reply) XXX_Unmarshal(b []byte) error + type Request struct + Msg string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) GetMsg() string + func (m *Request) Reset() + func (m *Request) String() string + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type StreamsClient interface + FullDuplex func(ctx context.Context, opts ...grpc.CallOption) (Streams_FullDuplexClient, error) + HalfDuplex func(ctx context.Context, in *Request, opts ...grpc.CallOption) (Streams_HalfDuplexClient, error) + func NewStreamsClient(cc *grpc.ClientConn) StreamsClient + type StreamsServer interface + FullDuplex func(Streams_FullDuplexServer) error + HalfDuplex func(*Request, Streams_HalfDuplexServer) error + type Streams_FullDuplexClient interface + Recv func() (*Reply, error) + Send func(*Request) error + type Streams_FullDuplexServer interface + Recv func() (*Request, error) + Send func(*Reply) error + type Streams_HalfDuplexClient interface + Recv func() (*Reply, error) + type Streams_HalfDuplexServer interface + Send func(*Reply) error + type UnimplementedStreamsServer struct + func (*UnimplementedStreamsServer) FullDuplex(srv Streams_FullDuplexServer) error + func (*UnimplementedStreamsServer) HalfDuplex(req *Request, srv Streams_HalfDuplexServer) error