cherami

Jun 8, 2017

Changes in this version

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

+ type InboundOptions struct

+ ConsumerGroup string

+ Destination string

+ PrefetchCount int

+ type OutboundOptions struct

+ Destination string

+ type TransportConfig struct

+ Address string

+ DeploymentStr string

+ PeerList string

+ Timeout time.Duration

+ type TransportSpecOption func(*transportSpec)

+ func DefaultPeerList(path string) TransportSpecOption

Feb 2, 2017

Changes in this version

+ 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

+ ConsumerGroup string

+ Destination string

+ PrefetchCount int

+ Timeout time.Duration

+ type Outbound struct

+ func (o *Outbound) CallOneway(ctx context.Context, req *transport.Request) (transport.Ack, 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

+ Destination string

+ type Transport struct

+ func NewTransport(client cherami.Client) *Transport

+ func (t *Transport) IsRunning() bool

+ func (t *Transport) NewInbound(config InboundConfig) *Inbound

+ func (t *Transport) NewOutbound(config OutboundConfig) *Outbound

+ func (t *Transport) Start() error

+ func (t *Transport) Stop() error