Rename OneConnPool to SingleConnPool.

This commit is contained in:
Vladimir Mihailenco 2012-08-06 17:04:30 +03:00
parent ee618a6290
commit b2805a5e04
3 changed files with 9 additions and 9 deletions

View File

@ -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
}

View File

@ -20,7 +20,7 @@ func newPubSubClient(client *Client) (*PubSubClient, error) {
c := &PubSubClient{
Client: &Client{
ConnPool: NewOneConnPool(pubSubConn),
ConnPool: NewSingleConnPool(pubSubConn),
},
ch: make(chan *Message),
}

View File

@ -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 {