(addr string, auth string, timeout time.Duration)
| 33 | } |
| 34 | |
| 35 | func NewClient(addr string, auth string, timeout time.Duration) (*Client, error) { |
| 36 | c, err := redigo.Dial("tcp", addr, []redigo.DialOption{ |
| 37 | redigo.DialConnectTimeout(math2.MinDuration(time.Second, timeout)), |
| 38 | redigo.DialPassword(auth), |
| 39 | redigo.DialReadTimeout(timeout), redigo.DialWriteTimeout(timeout), |
| 40 | }...) |
| 41 | if err != nil { |
| 42 | return nil, errors.Trace(err) |
| 43 | } |
| 44 | return &Client{ |
| 45 | conn: c, Addr: addr, Auth: auth, |
| 46 | LastUse: time.Now(), Timeout: timeout, |
| 47 | }, nil |
| 48 | } |
| 49 | |
| 50 | func (c *Client) Close() error { |
| 51 | return c.conn.Close() |
no outgoing calls
no test coverage detected