feat: extend ExponentialBackOff in cluster-proxy service (#672)

krystiancastai · web-flow · commit fe504762ffe1 · 2026-03-17T08:14:30.000+01:00
diff --git a/pkg/clusterproxy/client.go b/pkg/clusterproxy/client.go
@@ -77,7 +77,7 @@ func (c *Client) Run(ctx context.Context) error {
 
 	eb := backoff.NewExponentialBackOff()
 	eb.InitialInterval = 1 * time.Second
-	eb.MaxInterval = 30 * time.Second
+	eb.MaxInterval = 5 * time.Minute
 
 	op := func() (struct{}, error) {
 		err := c.subscribe(ctx)
@@ -90,6 +90,7 @@ func (c *Client) Run(ctx context.Context) error {
 
 	_, err := backoff.Retry(ctx, op,
 		backoff.WithBackOff(eb),
+		backoff.WithMaxElapsedTime(0),
 	)
 	return err
 }

Original file line number	Diff line number	Diff line change
`@@ -77,7 +77,7 @@ func (c *Client) Run(ctx context.Context) error {`
`77`	`77`
`78`	`78`	`eb := backoff.NewExponentialBackOff()`
`79`	`79`	`eb.InitialInterval = 1 * time.Second`
`80`		`- eb.MaxInterval = 30 * time.Second`
	`80`	`+ eb.MaxInterval = 5 * time.Minute`
`81`	`81`
`82`	`82`	`op := func() (struct{}, error) {`
`83`	`83`	`err := c.subscribe(ctx)`
`@@ -90,6 +90,7 @@ func (c *Client) Run(ctx context.Context) error {`
`90`	`90`
`91`	`91`	`_, err := backoff.Retry(ctx, op,`
`92`	`92`	`backoff.WithBackOff(eb),`
	`93`	`+ backoff.WithMaxElapsedTime(0),`
`93`	`94`	`)`
`94`	`95`	`return err`
`95`	`96`	`}`