Versions in this module Expand all Collapse all v1 v1.0.1 Dec 2, 2019 v1.0.0 Sep 5, 2019 Changes in this version + var BUFFER_FULL_KILL bool = true + var NOP_AFTER int = 50 + var QUORUM bool = false + func LoadNodeList(filename string) []string + type Conn struct + func NewConn(addr string) *Conn + func (n *Conn) BitAnd(key, subkey []byte, value int64, sync bool) int64 + func (n *Conn) BitAndNot(key, subkey []byte, value int64, sync bool) int64 + func (n *Conn) BitOr(key, subkey []byte, value int64, sync bool) int64 + func (n *Conn) BitXor(key, subkey []byte, value int64, sync bool) int64 + func (n *Conn) Dec(key, subkey []byte, val int64, sync bool) int64 + func (n *Conn) Del(key, subkey []byte, sync bool) bool + func (n *Conn) Do(command pb.LCPROTO_Code, key, subkey, value []byte) *pb.LCPROTO + func (n *Conn) Get(key, subkey []byte) []byte + func (n *Conn) GetInt(key, subkey []byte) int64 + func (n *Conn) HAll(hash []byte) []Pair + func (n *Conn) HKeys(key []byte, limit, offset int64) [][]byte + func (n *Conn) HKeysAll(hash []byte) [][]byte + func (n *Conn) HKeysRand(key []byte, limit int64) [][]byte + func (n *Conn) HKill(key []byte, sync bool) + func (n *Conn) HSize(key []byte) int64 + func (n *Conn) Has(key, subkey []byte) bool + func (n *Conn) Inc(key, subkey []byte, val int64, sync bool) int64 + func (n *Conn) KeepAlive() bool + func (n *Conn) KeyTotal() int64 + func (n *Conn) Log(key, value []byte, counter int) + func (n *Conn) Nop() + func (n *Conn) Read() *pb.LCPROTO + func (n *Conn) Release() + func (n *Conn) Send(command pb.LCPROTO_Code, key, subkey, value []byte) + func (n *Conn) SeqAdd(seq []byte, value interface{}, sync bool) + func (n *Conn) SeqKill(seq []byte, sync bool) + func (n *Conn) SeqRange(seq []byte, limit, offset int64) [][]byte + func (n *Conn) SeqSize(seq []byte) int64 + func (n *Conn) Set(key, subkey []byte, value interface{}, sync bool) + func (n *Conn) SetIfMore(key, subkey []byte, val int64, sync bool) int64 + func (n *Conn) SetNX(key, subkey []byte, val interface{}, sync bool) bool + func (n *Conn) ZKill(key []byte, sync bool) + func (n *Conn) ZRange(key []byte, limit, offset, min, max int64) []ZRec + func (n *Conn) ZRangeSize(key []byte, min, max int64) int64 + type MultiProxy struct + func MultiProxyFromFile(filename string) *MultiProxy + func MultiProxyFromMap(conf map[string][]string) *MultiProxy + func (mp *MultiProxy) Get(name string) *Proxy + type Pair struct + Key []byte + Value []byte + type Pool struct + Addr string + func NewPool(addr string, limit int) *Pool + func (p *Pool) Get() (c *Conn) + func (p *Pool) Put(c *Conn) + type Proxy struct + func NewProxy(addrs []string) *Proxy + func (p *Proxy) BitAnd(key, subkey []byte, value int64, sync bool) int64 + func (p *Proxy) BitAndNot(key, subkey []byte, value int64, sync bool) int64 + func (p *Proxy) BitOr(key, subkey []byte, value int64, sync bool) int64 + func (p *Proxy) BitXor(key, subkey []byte, value int64, sync bool) int64 + func (p *Proxy) Dec(key, subkey []byte, val int64, sync bool) int64 + func (p *Proxy) Del(key, subkey []byte, sync bool) bool + func (p *Proxy) Get(key, subkey []byte) []byte + func (p *Proxy) GetInt(key, subkey []byte) int64 + func (p *Proxy) HAll(key []byte) []Pair + func (p *Proxy) HKeys(key []byte, limit, offset int64) [][]byte + func (p *Proxy) HKeysAll(key []byte) [][]byte + func (p *Proxy) HKeysRand(key []byte, limit int64) [][]byte + func (p *Proxy) HKill(key []byte, sync bool) + func (p *Proxy) HSize(key []byte) int64 + func (p *Proxy) Has(key, subkey []byte) bool + func (p *Proxy) Inc(key, subkey []byte, val int64, sync bool) int64 + func (p *Proxy) KeyTotal(n int) int64 + func (p *Proxy) ProtoDo(msg *pb.LCPROTO) *pb.LCPROTO + func (p *Proxy) ProtoSend(msg *pb.LCPROTO) + func (p *Proxy) SeqAdd(seq []byte, value interface{}, sync bool) + func (p *Proxy) SeqKill(seq []byte, sync bool) + func (p *Proxy) SeqRange(seq []byte, limit, offset int64) [][]byte + func (p *Proxy) SeqSize(seq []byte) int64 + func (p *Proxy) Set(key, subkey []byte, value interface{}, sync bool) + func (p *Proxy) SetIfMore(key, subkey []byte, value int64, sync bool) int64 + func (p *Proxy) SetNX(key, subkey []byte, value interface{}, sync bool) bool + func (p *Proxy) Status() bool + func (p *Proxy) ZKill(key []byte, sync bool) + func (p *Proxy) ZRange(key []byte, limit, offset, min, max int64) []ZRec + func (p *Proxy) ZRangeSize(key []byte, min, max int64) int64 + type ZRec struct + Key []byte + Value int64