proto

package

Go to main page

Versions in this module

v1

v1.5.3

Jan 2, 2019

v1.5.2

Dec 21, 2018

v1.5.1

Dec 17, 2018

v1.5.0

Dec 5, 2018

Changes in this version

+ type Forwarder interface

+ Close func() error

+ Forward func([]*Message) error

type Message

+ func (m *Message) Add()

+ func (m *Message) Done()

+ func (m *Message) WithWaitGroup(wg *sync.WaitGroup)

type NodeConn

+ Flush func() error

+ Read func(*Message) error

+ Write func(*Message) error

+ type NodeConnPipe struct

+ func NewNodeConnPipe(conns int32, newNc func() NodeConn) (ncp *NodeConnPipe)

+ func (ncp *NodeConnPipe) Close()

+ func (ncp *NodeConnPipe) ErrorEvent() <-chan error

+ func (ncp *NodeConnPipe) Push(m *Message)

v1.4.0

Oct 18, 2018

Changes in this version

type CacheType

+ const CacheTypeRedisCluster

type MsgBatch

+ func (m *MsgBatch) DoneWithError(cluster, addr string, err error)

v1.3.2

Sep 12, 2018

Changes in this version

+ func PutMsgBatchAllocator(mba *MsgBatchAllocator)

+ type Executor interface

+ Close func() error

+ Execute func(mba *MsgBatchAllocator, msgs []*Message) error

type Message

+ func (m *Message) WithError(err error)

+ type MsgBatchAllocator struct

+ func GetMsgBatchAllocator() *MsgBatchAllocator

+ func (m *MsgBatchAllocator) Add(delta int)

+ func (m *MsgBatchAllocator) AddMsg(node string, msg *Message)

+ func (m *MsgBatchAllocator) MsgBatchs() map[string]*MsgBatch

+ func (m *MsgBatchAllocator) Reset()

+ func (m *MsgBatchAllocator) Wait()

+ type Pinger interface

+ Close func() error

+ Ping func() error

v1.2.1

Aug 6, 2018

Changes in this version

+ var ErrNoSupportCacheType = errs.New("unsupported cache type")

+ func PutMsgBatchs(mbs []*MsgBatch)

+ func PutMsgs(msgs []*Message)

+ type CacheType string

+ const CacheTypeMemcache

+ const CacheTypeMemcacheBinary

+ const CacheTypeRedis

+ const CacheTypeUnknown

+ type Message struct

+ Type CacheType

+ func ErrMessage(err error) *Message

+ func GetMsgs(n int, caps ...int) []*Message

+ func NewMessage() *Message

+ func (m *Message) Batch() []*Message

+ func (m *Message) DoneWithError(err error)

+ func (m *Message) Err() error

+ func (m *Message) IsBatch() bool

+ func (m *Message) MarkEnd()

+ func (m *Message) MarkRead()

+ func (m *Message) MarkStart()

+ func (m *Message) MarkWrite()

+ func (m *Message) NextReq() (req Request)

+ func (m *Message) RemoteDur() time.Duration

+ func (m *Message) Request() Request

+ func (m *Message) Requests() []Request

+ func (m *Message) Reset()

+ func (m *Message) ResetSubs()

+ func (m *Message) TotalDur() time.Duration

+ func (m *Message) WithRequest(req Request)

+ type MsgBatch struct

+ func GetMsgBatchs(n int) []*MsgBatch

+ func NewMsgBatch() *MsgBatch

+ func (m *MsgBatch) Add(n int)

+ func (m *MsgBatch) AddMsg(msg *Message)

+ func (m *MsgBatch) BatchDone(cluster, addr string)

+ func (m *MsgBatch) BatchDoneWithError(cluster, addr string, err error)

+ func (m *MsgBatch) Buffer() *bufio.Buffer

+ func (m *MsgBatch) Count() int

+ func (m *MsgBatch) Done()

+ func (m *MsgBatch) Msgs() []*Message

+ func (m *MsgBatch) Nth(i int) *Message

+ func (m *MsgBatch) Reset()

+ func (m *MsgBatch) Wait()

+ type MsgChan struct

+ func NewMsgChan() *MsgChan

+ func NewMsgChanBuffer(n int) *MsgChan

+ func (c *MsgChan) Buffered() int

+ func (c *MsgChan) Close()

+ func (c *MsgChan) Closed() bool

+ func (c *MsgChan) PopFront() (*Message, bool)

+ func (c *MsgChan) PushBack(r *Message) int

+ type NodeConn interface

+ Close func() error

+ Ping func() error

+ ReadBatch func(*MsgBatch) error

+ WriteBatch func(*MsgBatch) error

+ type ProxyConn interface

+ Decode func([]*Message) ([]*Message, error)

+ Encode func(msg *Message) error

+ Flush func() error

+ type Request interface

+ Cmd func() []byte

+ CmdString func() string

+ Key func() []byte

+ Put func()

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL