Versions in this module Expand all Collapse all v1 v1.0.0 Jan 4, 2023 Changes in this version + const VERSION + func Delete(tags ...string) (bool, float64, error) + func GetKeys() ([]interface{}, float64, error) + func GetUsers() ([]string, float64, error) + func NewClient(params map[string]interface{}) + func PipeAll(tag string) (interface{}, float64, error) + func PipeLength(tag string) (int64, float64, error) + func PipePull(tag, ptype string) (int64, interface{}, float64, error) + func PipePush(key string, value interface{}) (int64, float64, error) + func Read(tags ...string) (interface{}, float64, error) + func SelfDecrease(tag string) (int64, float64, error) + func SelfIncrease(tag string) (int64, float64, error) + func ServerTime() (time.Time, float64, error) + func Write(key string, value interface{}) (interface{}, float64, error) + func Writes(kvs map[string]interface{}) (interface{}, float64, error) + type ConnHandel struct + Conn net.Conn + ConnServer bool + CreatedAt time.Time + Id int64 + Logged bool + LoginAt time.Time + LoseServerAt time.Time + RxBytes int64 + RxTimes int64 + TxBytes int64 + TxTimes int64 + WorkeAt time.Time + Working bool + type ConnPool struct + ConnChan chan *ConnHandel + Conns []*ConnHandel + ReqChan chan int + Version string + WorkerChan chan int + func NewConnPool(params map[string]interface{}) *ConnPool + func (p *ConnPool) Delete(tags ...string) (bool, float64, error) + func (p *ConnPool) GetKeys() ([]interface{}, float64, error) + func (p *ConnPool) GetUsers() ([]string, float64, error) + func (p *ConnPool) PipeAll(tag string) (interface{}, float64, error) + func (p *ConnPool) PipeLength(tag string) (int64, float64, error) + func (p *ConnPool) PipePull(tag, ptype string) (int64, interface{}, float64, error) + func (p *ConnPool) PipePush(key string, value interface{}) (int64, float64, error) + func (p *ConnPool) Read(tags ...string) (interface{}, float64, error) + func (p *ConnPool) Request(funcCode byte, msg interface{}) (*RespMsg, float64, error) + func (p *ConnPool) SelfDecrease(tag string) (int64, float64, error) + func (p *ConnPool) SelfIncrease(tag string) (int64, float64, error) + func (p *ConnPool) ServerTime() (time.Time, float64, error) + func (p *ConnPool) Write(key string, val interface{}) (interface{}, float64, error) + func (p *ConnPool) Writes(kvs map[string]interface{}) (interface{}, float64, error) + type RespMsg struct + Data interface{} + Msg string + Ok bool + func Request(funcCode byte, msg interface{}) (*RespMsg, float64, error) + type UserMsg struct + Password string + Username string