fix: align wait time to aggregated backoff

softonic · Jan 31, 2025 · 15829ce · 15829ce
1 parent d3fd4b2
commit 15829ce
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/pkg/middleware/manager.go b/pkg/middleware/manager.go
@@ -50,7 +50,7 @@ func (m *MiddlwareManager) Start() {
 
 		// wait for ready up to 12 seconds (including retries)
 		// to handle service discontinuity (external middlewares) or startup order
-		ctxTimeout, cancelTimeout := context.WithTimeout(context.Background(), 12*time.Second)
+		ctxTimeout, cancelTimeout := context.WithTimeout(context.Background(), 31*time.Second)
 		handleData, err := client.Handle(ctxTimeout, &proto.Data{
 			Body: message.Body,
 		}, grpc.WaitForReady(true))

diff --git a/pkg/middleware/unimplemented.go b/pkg/middleware/unimplemented.go
@@ -22,7 +22,7 @@ type UnimplementedMiddleware struct {
 func (b *UnimplementedMiddleware) Next(req *proto.Data) (*proto.Data, error) {
 	if b.client != nil {
 		klog.V(0).Info("processing next middleware")
-		ctxTimeout, cancelTimeout := context.WithTimeout(context.Background(), 12*time.Second)
+		ctxTimeout, cancelTimeout := context.WithTimeout(context.Background(), 31*time.Second)
 		nextResp, err := (*b.client).Handle(ctxTimeout, req, grpc.WaitForReady(true))
 		cancelTimeout()
 		if err != nil {