Versions in this module Expand all Collapse all v1 v1.9.1 Sep 5, 2019 Changes in this version + func RegisterTransportHandler(s server.Server, hdlr TransportHandler, opts ...server.HandlerOption) error + func RegisterTransportServer(s *grpc.Server, srv TransportServer) + type Message struct + Body []byte + Header map[string]string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + func (m *Message) GetBody() []byte + func (m *Message) GetHeader() map[string]string + func (m *Message) Reset() + func (m *Message) String() string + func (m *Message) XXX_DiscardUnknown() + func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Message) XXX_Merge(src proto.Message) + func (m *Message) XXX_Size() int + func (m *Message) XXX_Unmarshal(b []byte) error + type TransportClient interface + Stream func(ctx context.Context, opts ...grpc.CallOption) (Transport_StreamClient, error) + func NewTransportClient(cc *grpc.ClientConn) TransportClient + type TransportHandler interface + Stream func(context.Context, Transport_StreamStream) error + type TransportServer interface + Stream func(Transport_StreamServer) error + type TransportService interface + Stream func(ctx context.Context, opts ...client.CallOption) (Transport_StreamService, error) + func NewTransportService(name string, c client.Client) TransportService + type Transport_StreamClient interface + Recv func() (*Message, error) + Send func(*Message) error + type Transport_StreamServer interface + Recv func() (*Message, error) + Send func(*Message) error + type Transport_StreamService interface + Close func() error + Recv func() (*Message, error) + RecvMsg func(interface{}) error + Send func(*Message) error + SendMsg func(interface{}) error + type Transport_StreamStream interface + Close func() error + Recv func() (*Message, error) + RecvMsg func(interface{}) error + Send func(*Message) error + SendMsg func(interface{}) error