diff --git a/cluster.go b/cluster.go index 9aa51fb..a8115b4 100644 --- a/cluster.go +++ b/cluster.go @@ -653,6 +653,8 @@ func NewClusterClient(opt *ClusterOptions) *ClusterClient { c.init() _, _ = c.state.Reload() + _, _ = c.cmdsInfoCache.Get() + if opt.IdleCheckFrequency > 0 { go c.reaper(opt.IdleCheckFrequency) } diff --git a/cluster_test.go b/cluster_test.go index db0728d..80b4d02 100644 --- a/cluster_test.go +++ b/cluster_test.go @@ -853,8 +853,8 @@ var _ = Describe("ClusterClient timeout", func() { Context("read/write timeout", func() { BeforeEach(func() { opt := redisClusterOptions() - opt.ReadTimeout = 300 * time.Millisecond - opt.WriteTimeout = 300 * time.Millisecond + opt.ReadTimeout = 250 * time.Millisecond + opt.WriteTimeout = 250 * time.Millisecond opt.MaxRedirects = 1 client = cluster.clusterClient(opt)