func (r *RedisConn) Connect(cmdCh chan *storage.CommandBundle,
	conntype, addr string, _ ...interface{}) error {
	conn, err := redis.Dial(conntype, addr)
	if err != nil {
		gslog.Errorf("connecting to redis at %s: %s", addr, err)
		return err
	}

	r.conntype = conntype
	r.addr = addr
	r.conn = conn
	r.cmdCh = cmdCh
	r.closeCh = make(chan chan error)
	go r.spin()
	return nil
}
// Implements Connect for Storage. Connects to redis over tcp and spawns a
// handler go-routine
Implements Connect for Storage. Connects to redis over tcp and spawns a
handler go-routine
// Implements Connect for Storage . Connects to redis over tcp and spawns a // handler go - routine
func (r *RedisConn) Connect(cmdCh chan *storage.CommandBundle,
	conntype, addr string, _ ...interface{}) error {
	conn, err := redis.Dial(conntype, addr)
	if err != nil {
		gslog.Errorf("connecting to redis at %s: %s", addr, err)
		return err
	}
	r.conntype = conntype
	r.addr = addr
	r.conn = conn
	r.cmdCh = cmdCh
	r.closeCh = make(chan chan error)
	go r.spin()
	return nil
}
func ( r * RedisConn ) Connect ( cmdCh chan * storage . CommandBundle , conntype , addr string , _ ... interface { } ) error { conn , err := redis . Dial ( conntype , addr ) if err != nil { gslog . Errorf ( " " , addr , err ) return err } r . conntype = conntype r . addr = addr r . conn = conn r . cmdCh = cmdCh r . closeCh = make ( chan chan error ) go r . spin ( ) return nil }
Implements Connect for Storage.
Implements Connect for Storage .