feat(cluster): Add retry delay for the gRPC dial

cluster/cluster.go

@@ -143,6 +143,7 @@ func (c *cluster) establishNewConnection(host string) (*grpc.ClientConn, error)
 			)
 		},
 		retry.WithRetryCount(c.options.ConnectRetryCount),
+		retry.WithDelay(c.options.ConnectRetryDelay),
 	)
 	if err != nil {
 		return nil, err

cluster/options.go

@@ -14,6 +14,9 @@ type Options struct {
 	// ConnectRetryCount specifies the maximum number of retries to connect to other nodes.
 	ConnectRetryCount int `default:"10"`
 
+	// ConnectRetryDelay specifies the delay between retries to connect to other nodes.
+	ConnectRetryDelay time.Duration `default:"200ms"`
+
 	// MaxMessageSize specifies the maximum message size in bytes the gRPC client can receive/send.
 	// The default value is 500mb.
 	MaxMessageSize int `default:"524288000"`

pkg/retry/option.go

@@ -1,12 +1,16 @@
 package retry
 
+import "time"
+
 type option struct {
 	maxRetryCount int
+	delay         time.Duration
 }
 
 func defaultOption() option {
 	return option{
 		maxRetryCount: 3,
+		delay:         200 * time.Millisecond,
 	}
 }
 
@@ -19,3 +23,10 @@ func WithRetryCount(count int) OptionFunc {
 		o.maxRetryCount = count
 	}
 }
+
+// WithDelay sets the delay between retries.
+func WithDelay(delay time.Duration) OptionFunc {
+	return func(o *option) {
+		o.delay = delay
+	}
+}