kettle/rds/client.go

package rds

import (
	"github.com/go-redis/redis"
	"time"
)

func Connect(addr, password string, db int) (*redis.Client, error) {
	conn := redis.NewClient(&redis.Options{
		Addr:         addr,
		Password:     password,
		DB:           db,
		DialTimeout:  3 * time.Second,
		ReadTimeout:  3 * time.Second,
		WriteTimeout: 5 * time.Second,
		PoolSize:     10,
		PoolTimeout:  60 * time.Second,
	})
	_, err := conn.Ping().Result()
	if nil != err {
		return nil, err
	}
	return conn, nil
}