diff --git a/connpool.go b/connpool.go index c14ada9..361187a 100644 --- a/connpool.go +++ b/connpool.go @@ -105,22 +105,22 @@ func (p *MultiConnPool) Len() int { //------------------------------------------------------------------------------ -type OneConnPool struct { +type SingleConnPool struct { conn *Conn } -func NewOneConnPool(conn *Conn) *OneConnPool { - return &OneConnPool{conn: conn} +func NewSingleConnPool(conn *Conn) *SingleConnPool { + return &SingleConnPool{conn: conn} } -func (p *OneConnPool) Get() (*Conn, bool, error) { +func (p *SingleConnPool) Get() (*Conn, bool, error) { return p.conn, false, nil } -func (p *OneConnPool) Add(conn *Conn) {} +func (p *SingleConnPool) Add(conn *Conn) {} -func (p *OneConnPool) Remove(conn *Conn) {} +func (p *SingleConnPool) Remove(conn *Conn) {} -func (p *OneConnPool) Len() int { +func (p *SingleConnPool) Len() int { return 1 } diff --git a/pubsub.go b/pubsub.go index 080ad09..e9f95d1 100644 --- a/pubsub.go +++ b/pubsub.go @@ -20,7 +20,7 @@ func newPubSubClient(client *Client) (*PubSubClient, error) { c := &PubSubClient{ Client: &Client{ - ConnPool: NewOneConnPool(pubSubConn), + ConnPool: NewSingleConnPool(pubSubConn), }, ch: make(chan *Message), } diff --git a/redis.go b/redis.go index 01baf76..213367f 100644 --- a/redis.go +++ b/redis.go @@ -88,7 +88,7 @@ func (c *Client) conn() (*Conn, error) { } if isNew && c.InitConn != nil { client := &Client{ - ConnPool: NewOneConnPool(conn), + ConnPool: NewSingleConnPool(conn), } err = c.InitConn(client) if err != nil {