go_micro_transport_grpc

Documentation

Index

• func NewTransportEndpoints() []*api.Endpoint
• func RegisterTransportHandler(s server.Server, hdlr TransportHandler, opts ...server.HandlerOption) error
• type TransportHandler
• type TransportService
  • func NewTransportService(name string, c client.Client) TransportService
• type Transport_StreamService
• type Transport_StreamStream

Functions

func NewTransportEndpoints

func NewTransportEndpoints() []*api.Endpoint

func RegisterTransportHandler

func RegisterTransportHandler(s server.Server, hdlr TransportHandler, opts ...server.HandlerOption) error

Types

type TransportHandler

type TransportHandler interface {
	Stream(context.Context, Transport_StreamStream) 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_StreamService

type Transport_StreamService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*Message) error
	Recv() (*Message, error)
}

type Transport_StreamStream

type Transport_StreamStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*Message) error
	Recv() (*Message, error)
}