Documentation ¶
Overview ¶
Package go_micro_grpc_transport is a generated protocol buffer package.
It is generated from these files:
github.com/micro/go-plugins/transport/grpc/proto/transport.proto
It has these top-level messages:
Message
Package go_micro_grpc_transport is a generated protocol buffer package.
It is generated from these files:
github.com/micro/go-plugins/transport/grpc/proto/transport.proto
It has these top-level messages:
Message
Index ¶
- func RegisterTransportHandler(s server.Server, hdlr TransportHandler, opts ...server.HandlerOption)
- func RegisterTransportServer(s *grpc.Server, srv TransportServer)
- type Message
- type TransportClient
- type TransportHandler
- type TransportServer
- type TransportService
- type Transport_StreamClient
- type Transport_StreamServer
- type Transport_StreamService
- type Transport_StreamStream
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterTransportHandler ¶
func RegisterTransportHandler(s server.Server, hdlr TransportHandler, opts ...server.HandlerOption)
func RegisterTransportServer ¶
func RegisterTransportServer(s *grpc.Server, srv TransportServer)
Types ¶
type Message ¶
type Message struct { Header map[string]string `` /* 132-byte string literal not displayed */ Body []byte `protobuf:"bytes,2,opt,name=body,proto3" json:"body,omitempty"` }
func (*Message) Descriptor ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
type TransportClient ¶
type TransportClient interface {
Stream(ctx context.Context, opts ...grpc.CallOption) (Transport_StreamClient, error)
}
func NewTransportClient ¶
func NewTransportClient(cc *grpc.ClientConn) TransportClient
type TransportHandler ¶
type TransportHandler interface {
Stream(context.Context, Transport_StreamStream) error
}
type TransportServer ¶
type TransportServer interface {
Stream(Transport_StreamServer) error
}
type TransportService ¶
type TransportService interface {
Stream(ctx context.Context, opts ...client.CallOption) (Transport_StreamService, error)
}
func NewTransportService ¶
func NewTransportService(name string, c client.Client) TransportService
type Transport_StreamClient ¶
type Transport_StreamServer ¶
type Transport_StreamService ¶
Click to show internal directories.
Click to hide internal directories.