test(retry): achieve full coverage

Author: gaby

addon/retry/config_test.go

@@ -0,0 +1,33 @@
+package retry
+
+import (
+	"testing"
+	"time"
+
+	"github.com/stretchr/testify/require"
+)
+
+func TestConfigDefault_NoConfig(t *testing.T) {
+	t.Parallel()
+	cfg := configDefault()
+	require.Equal(t, DefaultConfig, cfg)
+}
+
+func TestConfigDefault_Custom(t *testing.T) {
+	t.Parallel()
+	custom := Config{
+		InitialInterval: 2 * time.Second,
+		MaxBackoffTime:  64 * time.Second,
+		Multiplier:      3.0,
+		MaxRetryCount:   5,
+		currentInterval: 2 * time.Second,
+	}
+	cfg := configDefault(custom)
+	require.Equal(t, custom, cfg)
+}
+
+func TestConfigDefault_PartialAndNegative(t *testing.T) {
+	t.Parallel()
+	cfg := configDefault(Config{Multiplier: -1, MaxRetryCount: 0})
+	require.Equal(t, DefaultConfig, cfg)
+}

addon/retry/exponential_backoff_test.go

@@ -1,6 +1,7 @@
 package retry
 
 import (
+	"crypto/rand"
 	"errors"
 	"testing"
 	"time"
@@ -119,3 +120,27 @@ func Test_ExponentialBackoff_Next(t *testing.T) {
 		})
 	}
 }
+
+func Test_ExponentialBackoff_NextRandFailure(t *testing.T) {
+	t.Parallel()
+	// Backup original reader and restore at the end
+	original := rand.Reader
+	defer func() { rand.Reader = original }()
+	rand.Reader = failingReader{}
+
+	expBackoff := &ExponentialBackoff{
+		InitialInterval: 1 * time.Second,
+		MaxBackoffTime:  10 * time.Second,
+		Multiplier:      2,
+		MaxRetryCount:   3,
+		currentInterval: 1 * time.Second,
+	}
+	next := expBackoff.next()
+	require.Equal(t, expBackoff.MaxBackoffTime, next)
+	// currentInterval should not change when random fails
+	require.Equal(t, 1*time.Second, expBackoff.currentInterval)
+}
+
+type failingReader struct{}
+
+func (failingReader) Read(p []byte) (int, error) { return 0, errors.New("fail") }