add redis

go.mod

@@ -5,7 +5,7 @@ go 1.14
 require (
 	github.com/Shopify/sarama v1.19.0
 	github.com/bsm/sarama-cluster v2.1.15+incompatible
-	github.com/chasex/redis-go-cluster v1.0.0
+	github.com/chasex/redis-go-cluster v1.0.1-0.20161207023922-222d81891f1d
 	github.com/dgrijalva/jwt-go v3.2.0+incompatible
 	github.com/eapache/go-resiliency v1.2.0 // indirect
 	github.com/fastly/go-utils v0.0.0-20180712184237-d95a45783239 // indirect

utils/redis/redis_conn.go

@@ -16,7 +16,7 @@ import (
 type Hub struct {
 	LOG     func() *logger.Logger
 	pool    *redis.Pool
-	cluster redisc.Cluster
+	cluster *redisc.Cluster
 	once    sync.Once
 }
 
@@ -120,7 +120,9 @@ func (h *Hub) Close() error {
 		return nil
 	}
 	var err error
-	if nil != h.pool {
+	if nil != h.cluster {
+		h.cluster.Close()
+	} else if nil != h.pool {
 		err = h.pool.Close()
 	}
 	return err