Versions in this module Expand all Collapse all v4 v4.0.0 Feb 23, 2023 Changes in this version + func NewTransportEndpoints() []*api.Endpoint + 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 + Context func() context.Context + Recv func() (*Message, error) + RecvMsg func(interface{}) error + Send func(*Message) error + SendMsg func(interface{}) error + type Transport_StreamStream interface + Close func() error + Context func() context.Context + Recv func() (*Message, error) + RecvMsg func(interface{}) error + Send func(*Message) error + SendMsg func(interface{}) error + type UnimplementedTransportServer struct + func (*UnimplementedTransportServer) Stream(srv Transport_StreamServer) error
Go to main page