(addr string)
| 35 | } |
| 36 | |
| 37 | func NewConn(addr string) *Conn { |
| 38 | if t, err := net.ResolveTCPAddr("tcp", addr); err != nil { |
| 39 | Panic("parse tcp addr = %s, error = '%s'", addr, err) |
| 40 | } else if conn, err := redis.Dial("tcp", addr); err != nil { |
| 41 | Panic("connect to '%s' error = '%s'", addr, err) |
| 42 | } else { |
| 43 | return &Conn{conn, t.IP.String(), t.Port} |
| 44 | } |
| 45 | return nil |
| 46 | } |
| 47 | |
| 48 | func (c *Conn) Addr() string { |
| 49 | return c.Host + ":" + strconv.Itoa(c.Port) |