grpc

Sep 20, 2017

Changes in this version

type TransportConfig

+ ClientMaxRecvMsgSize int

+ ClientMaxSendMsgSize int

+ ServerMaxRecvMsgSize int

+ ServerMaxSendMsgSize int

Sep 15, 2017

Changes in this version

type TransportOption

+ func ClientMaxRecvMsgSize(clientMaxRecvMsgSize int) TransportOption

+ func ClientMaxSendMsgSize(clientMaxSendMsgSize int) TransportOption

+ func ServerMaxRecvMsgSize(serverMaxRecvMsgSize int) TransportOption

+ func ServerMaxSendMsgSize(serverMaxSendMsgSize int) TransportOption

Sep 8, 2017

Changes in this version

+ const CallerHeader

+ const EncodingHeader

+ const ErrorNameHeader

+ const RoutingDelegateHeader

+ const RoutingKeyHeader

+ const ServiceHeader

+ const ShardKeyHeader

+ type ContextWrapper struct

+ func NewContextWrapper() *ContextWrapper

+ func (c *ContextWrapper) WithCaller(caller string) *ContextWrapper

+ func (c *ContextWrapper) WithEncoding(encoding string) *ContextWrapper

+ func (c *ContextWrapper) WithRoutingDelegate(routingDelegate string) *ContextWrapper

+ func (c *ContextWrapper) WithRoutingKey(routingKey string) *ContextWrapper

+ func (c *ContextWrapper) WithService(service string) *ContextWrapper

+ func (c *ContextWrapper) WithShardKey(shardKey string) *ContextWrapper

+ func (c *ContextWrapper) Wrap(ctx context.Context) context.Context

type Outbound

+ func (o *Outbound) Chooser() peer.Chooser

type Transport

+ func (t *Transport) NewOutbound(peerChooser peer.Chooser, 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)

type TransportConfig

+ Backoff yarpcconfig.Backoff

type TransportOption

+ func BackoffStrategy(backoffStrategy backoff.Strategy) TransportOption

+ func Tracer(tracer opentracing.Tracer) TransportOption

Jun 8, 2017

Changes in this version

+ func TransportSpec(opts ...Option) config.TransportSpec

+ type InboundConfig struct

+ Address string

+ type Option interface

+ type OutboundConfig struct

+ Address string

+ 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) NewSingleOutbound(address string, options ...OutboundOption) *Outbound

+ func (t *Transport) Start() error

+ func (t *Transport) Stop() error

+ type TransportConfig struct

+ type TransportOption func(*transportOptions)

May 1, 2017

Changes in this version

+ const UserAgent

+ type Inbound struct

+ func NewInbound(listener net.Listener, options ...InboundOption) *Inbound

+ 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 InboundOption func(*inboundOptions)

+ func WithInboundTracer(tracer opentracing.Tracer) InboundOption

+ type Outbound struct

+ func NewSingleOutbound(address string, options ...OutboundOption) *Outbound

+ 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 OutboundOption func(*outboundOptions)

+ func WithOutboundTracer(tracer opentracing.Tracer) OutboundOption