redis

Dec 31, 2016

Changes in this version

+ type Client interface

+ BRPopLPush func(from, to string, timeout time.Duration) ([]byte, error)

+ ConnectionState func() string

+ Endpoint func() string

+ LPush func(queue string, item []byte) error

+ LRem func(queue string, item []byte) error

+ Start func() error

+ Stop func() error

+ func NewRedis5Client(addr string) Client

+ type Inbound struct

+ func NewInbound(client Client, queueKey, processingKey string, timeout time.Duration) *Inbound

+ func (i *Inbound) Introspect() introspection.InboundStatus

+ 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

+ func (i *Inbound) WithRouter(router transport.Router) *Inbound

+ func (i *Inbound) WithTracer(tracer opentracing.Tracer) *Inbound

+ type Outbound struct

+ func NewOnewayOutbound(client Client, queueKey string) *Outbound

+ func (o *Outbound) CallOneway(ctx context.Context, req *transport.Request) (transport.Ack, error)

+ func (o *Outbound) Introspect() introspection.OutboundStatus

+ func (o *Outbound) IsRunning() bool

+ func (o *Outbound) Start() error

+ func (o *Outbound) Stop() error

+ func (o *Outbound) Transports() []transport.Transport

+ func (o *Outbound) WithTracer(tracer opentracing.Tracer) *Outbound