relay

Aug 17, 2021

Changes in this version

+ type RespFrame interface

+ Arg2 func() []byte

+ Arg2IsFragmented func() bool

+ ArgScheme func() []byte

+ OK func() bool

Sep 19, 2020

Changes in this version

type CallFrame

+ Arg2Append func(key, val []byte)

type Conn

+ Context context.Context

+ type KeyVal struct

+ Key []byte

+ Val []byte

Feb 20, 2020

Changes in this version

type CallFrame

+ TTL func() time.Duration

Aug 27, 2019

Changes in this version

type CallFrame

+ Arg2EndOffset func() (_ int, hasMore bool)

+ Arg2Iterator func() (arg2.KeyValIterator, error)

+ Arg2StartOffset func() int

Nov 14, 2018

Changes in this version

type Conn

+ IsOutbound bool

+ RemoteAddr string

+ RemoteProcessName string

Dec 21, 2016

Changes in this version

+ type RateLimitDropError struct

+ func (e RateLimitDropError) Error() string

Sep 15, 2016

Changes in this version

type CallFrame

+ RoutingKey func() []byte

Aug 25, 2016

Changes in this version

type CallFrame

+ RoutingDelegate func() []byte

+ type Conn interface

+ RemoteHostPort func() string

+ RemoteProcessPrefixMatches func() []bool

Jul 16, 2016

Changes in this version

+ type CallFrame interface

+ Caller func() []byte

+ Method func() []byte

+ Service func() []byte

+ type CallStats interface

+ End func()

+ Failed func(reason string)

+ SetPeer func(Peer)

+ Succeeded func()

+ type Hosts interface

+ Get func(CallFrame) (Peer, error)

+ type Peer struct

+ HostPort string

+ Pool string

+ Zone string

+ type Stats interface

+ Begin func(CallFrame) CallStats

+ func NewNoopStats() Stats