Versions in this module Expand all Collapse all v1 v1.1.3 May 21, 2020 Changes in this version + type Avaliable interface + Available func() int + Pop func() int + Put func(int) + type Client struct + func (c *Client) Close() + type Connectors struct + EncodingFunc func(v interface{}) []byte + func NewConnectors(cfg *conf.Config) *Connectors + func (c *Connectors) Close() + func (c *Connectors) GetClient() *Client + func (c *Connectors) Info() string + func (c *Connectors) NewClient() (cli *Client, err error) + func (c *Connectors) SetNewClientRetryCount(count byte) + func (c *Connectors) Start() (err error) + type Pool struct + New func() (*Client, error) + func (p *Pool) CheckClose() + func (p *Pool) CheckHeath() + func (p *Pool) Close() + func (p *Pool) Get() (client *Client) + func (p *Pool) Set(client *Client) + func (p *Pool) Start() (err error) + type Queue struct + func (q *Queue) Available() int + func (q *Queue) Empty() (re bool) + func (q *Queue) Pop() (re int) + func (q *Queue) Put(i int) + type Ring struct + func (r *Ring) Available() int + func (r *Ring) Pop() int + func (r *Ring) Put(v int)