Fix hard code of failing timeout

1. if not set failing time limit, default is 15 seconds.

Author: trend-shino-wu

options.go

@@ -228,9 +228,14 @@ type Options struct {
 	// IdentitySuffix - add suffix to client name.
 	IdentitySuffix string
 
+<<<<<<< HEAD
 	// UnstableResp3 enables Unstable mode for Redis Search module with RESP3.
 	// When unstable mode is enabled, the client will use RESP3 protocol and only be able to use RawResult
 	UnstableResp3 bool
+=======
+	// Failing time limit for a node. Default is 15 seconds.
+	FailingTimeLimit int
+>>>>>>> 5ee5089 (Fix hard code of failing timeout)
 }
 
 func (opt *Options) init() {

osscluster.go

@@ -124,6 +124,8 @@ type ClusterOptions struct {
 
 	// UnstableResp3 enables Unstable mode for Redis Search module with RESP3.
 	UnstableResp3 bool
+
+	FailingTimeLimit int // Failing time limit for a node. Default is 15 seconds.
 }
 
 func (opt *ClusterOptions) init() {
@@ -180,6 +182,10 @@ func (opt *ClusterOptions) init() {
 	if opt.NewClient == nil {
 		opt.NewClient = NewClient
 	}
+
+	if opt.FailingTimeLimit == 0 {
+		opt.FailingTimeLimit = 15
+	}
 }
 
 // ParseClusterURL parses a URL into ClusterOptions that can be used to connect to Redis.
@@ -284,6 +290,7 @@ func setupClusterQueryParams(u *url.URL, o *ClusterOptions) (*ClusterOptions, er
 	o.PoolTimeout = q.duration("pool_timeout")
 	o.ConnMaxLifetime = q.duration("conn_max_lifetime")
 	o.ConnMaxIdleTime = q.duration("conn_max_idle_time")
+	o.FailingTimeLimit = q.int("failing_time_limit")
 
 	if q.err != nil {
 		return nil, q.err
@@ -343,6 +350,7 @@ func (opt *ClusterOptions) clientOptions() *Options {
 		DisableIdentity:  opt.DisableIdentity,
 		DisableIndentity: opt.DisableIdentity,
 		IdentitySuffix:   opt.IdentitySuffix,
+		FailingTimeLimit: opt.FailingTimeLimit,
 		TLSConfig:        opt.TLSConfig,
 		// If ClusterSlots is populated, then we probably have an artificial
 		// cluster whose nodes are not in clustering mode (otherwise there isn't
@@ -432,7 +440,7 @@ func (n *clusterNode) MarkAsFailing() {
 }
 
 func (n *clusterNode) Failing() bool {
-	const timeout = 15 // 15 seconds
+	timeout := int64(n.Client.opt.FailingTimeLimit)
 
 	failing := atomic.LoadUint32(&n.failing)
 	if failing == 0 {