Versions in this module Expand all Collapse all v1 v1.19.2 Oct 10, 2017 v1.19.1 Oct 10, 2017 Changes in this version type Outbound + func (o *Outbound) Chooser() peer.Chooser v1.19.0 Oct 10, 2017 Changes in this version + const ApplicationErrorHeader + const ApplicationErrorHeaderValue + const CallerHeader + const EncodingHeader + const ErrorNameHeader + const RoutingDelegateHeader + const RoutingKeyHeader + const ServiceHeader + const ShardKeyHeader + const UserAgent + func TransportSpec(opts ...Option) yarpcconfig.TransportSpec + type Inbound struct + func (i *Inbound) IsRunning() bool + func (i *Inbound) SetRouter(router transport.Router) + func (i *Inbound) Start() error + func (i *Inbound) Stop() error + func (i *Inbound) Transports() []transport.Transport + type InboundConfig struct + Address string + type InboundOption func(*inboundOptions) + type Option interface + type Outbound struct + func (o *Outbound) Call(ctx context.Context, request *transport.Request) (*transport.Response, error) + func (o *Outbound) IsRunning() bool + func (o *Outbound) Start() error + func (o *Outbound) Stop() error + func (o *Outbound) Transports() []transport.Transport + type OutboundConfig struct + Address string + type OutboundOption func(*outboundOptions) + type Transport struct + func NewTransport(options ...TransportOption) *Transport + func (t *Transport) IsRunning() bool + func (t *Transport) NewInbound(listener net.Listener, options ...InboundOption) *Inbound + func (t *Transport) NewOutbound(peerChooser peer.Chooser, options ...OutboundOption) *Outbound + func (t *Transport) NewSingleOutbound(address string, options ...OutboundOption) *Outbound + func (t *Transport) ReleasePeer(peerIdentifier peer.Identifier, peerSubscriber peer.Subscriber) error + func (t *Transport) RetainPeer(peerIdentifier peer.Identifier, peerSubscriber peer.Subscriber) (peer.Peer, error) + func (t *Transport) Start() error + func (t *Transport) Stop() error + type TransportConfig struct + Backoff yarpcconfig.Backoff + ClientMaxRecvMsgSize int + ClientMaxSendMsgSize int + ServerMaxRecvMsgSize int + ServerMaxSendMsgSize int + type TransportOption func(*transportOptions) + func BackoffStrategy(backoffStrategy backoff.Strategy) TransportOption + func ClientMaxRecvMsgSize(clientMaxRecvMsgSize int) TransportOption + func ClientMaxSendMsgSize(clientMaxSendMsgSize int) TransportOption + func ServerMaxRecvMsgSize(serverMaxRecvMsgSize int) TransportOption + func ServerMaxSendMsgSize(serverMaxSendMsgSize int) TransportOption + func Tracer(tracer opentracing.Tracer) TransportOption
Go to main page