diff --git a/internal/civisibility/utils/net/client.go b/internal/civisibility/utils/net/client.go index 5c988c4ceb..19cf446dbf 100644 --- a/internal/civisibility/utils/net/client.go +++ b/internal/civisibility/utils/net/client.go @@ -29,9 +29,9 @@ import ( const ( // DefaultMaxRetries is the default number of retries for a request. - DefaultMaxRetries int = 5 + DefaultMaxRetries int = 3 // DefaultBackoff is the default backoff time for a request. - DefaultBackoff time.Duration = 150 * time.Millisecond + DefaultBackoff time.Duration = 100 * time.Millisecond ) type ( diff --git a/internal/civisibility/utils/net/http.go b/internal/civisibility/utils/net/http.go index dc02abb734..ce1987d317 100644 --- a/internal/civisibility/utils/net/http.go +++ b/internal/civisibility/utils/net/http.go @@ -331,7 +331,7 @@ func decompressData(data []byte) ([]byte, error) { // exponentialBackoff performs an exponential backoff with retries. func exponentialBackoff(retryCount int, initialDelay time.Duration) { - maxDelay := 30 * time.Second + maxDelay := 10 * time.Second delay := initialDelay * (1 << uint(retryCount)) // Exponential backoff if delay > maxDelay { delay = maxDelay diff --git a/internal/civisibility/utils/net/http_test.go b/internal/civisibility/utils/net/http_test.go index 45a6c167bc..3200f1d5b7 100644 --- a/internal/civisibility/utils/net/http_test.go +++ b/internal/civisibility/utils/net/http_test.go @@ -786,9 +786,9 @@ func TestSendRequestWithInvalidRetryAfterHeader(t *testing.T) { func TestExponentialBackoffWithMaxDelay(t *testing.T) { start := time.Now() - exponentialBackoff(10, 1*time.Second) // Should be limited to maxDelay (30s) + exponentialBackoff(10, 1*time.Second) // Should be limited to maxDelay (10s) duration := time.Since(start) - assert.LessOrEqual(t, duration, 31*time.Second) + assert.LessOrEqual(t, duration, 11*time.Second) } func TestSendRequestWithContextTimeout(t *testing.T) {