move backoff to new package

Author: panotza

backoff.go backoff/backoff.gobackoff.go renamed to backoff/backoff.go

@@ -1,9 +1,11 @@
-package pgsql
+package backoff
 
 import (
 	"math"
 	"math/rand/v2"
 	"time"
+
+	"github.com/acoshift/pgsql"
 )
 
 // BackoffConfig contains common configuration for all backoff strategies
@@ -38,7 +40,7 @@ const (
 )
 
 // NewExponentialBackoff creates a new exponential backoff function
-func NewExponentialBackoff(config ExponentialBackoffConfig) BackoffDelayFunc {
+func NewExponentialBackoff(config ExponentialBackoffConfig) pgsql.BackoffDelayFunc {
 	return func(attempt int) time.Duration {
 		baseDelay := time.Duration(float64(config.BaseDelay) * math.Pow(config.Multiplier, float64(attempt)))
 		if baseDelay > config.MaxDelay {
@@ -71,7 +73,7 @@ func NewExponentialBackoff(config ExponentialBackoffConfig) BackoffDelayFunc {
 }
 
 // NewLinearBackoff creates a new linear backoff function
-func NewLinearBackoff(config LinearBackoffConfig) BackoffDelayFunc {
+func NewLinearBackoff(config LinearBackoffConfig) pgsql.BackoffDelayFunc {
 	return func(attempt int) time.Duration {
 		delay := config.BaseDelay + time.Duration(attempt)*config.Increment
 		if delay > config.MaxDelay {
@@ -81,7 +83,7 @@ func NewLinearBackoff(config LinearBackoffConfig) BackoffDelayFunc {
 	}
 }
 
-func DefaultExponentialBackoff() BackoffDelayFunc {
+func DefaultExponentialBackoff() pgsql.BackoffDelayFunc {
 	return NewExponentialBackoff(ExponentialBackoffConfig{
 		BackoffConfig: BackoffConfig{
 			BaseDelay: 100 * time.Millisecond,
@@ -92,7 +94,7 @@ func DefaultExponentialBackoff() BackoffDelayFunc {
 	})
 }
 
-func DefaultExponentialBackoffWithFullJitter() BackoffDelayFunc {
+func DefaultExponentialBackoffWithFullJitter() pgsql.BackoffDelayFunc {
 	return NewExponentialBackoff(ExponentialBackoffConfig{
 		BackoffConfig: BackoffConfig{
 			BaseDelay: 100 * time.Millisecond,
@@ -103,7 +105,7 @@ func DefaultExponentialBackoffWithFullJitter() BackoffDelayFunc {
 	})
 }
 
-func DefaultExponentialBackoffWithEqualJitter() BackoffDelayFunc {
+func DefaultExponentialBackoffWithEqualJitter() pgsql.BackoffDelayFunc {
 	return NewExponentialBackoff(ExponentialBackoffConfig{
 		BackoffConfig: BackoffConfig{
 			BaseDelay: 100 * time.Millisecond,
@@ -114,7 +116,7 @@ func DefaultExponentialBackoffWithEqualJitter() BackoffDelayFunc {
 	})
 }
 
-func DefaultLinearBackoff() BackoffDelayFunc {
+func DefaultLinearBackoff() pgsql.BackoffDelayFunc {
 	return NewLinearBackoff(LinearBackoffConfig{
 		BackoffConfig: BackoffConfig{
 			BaseDelay: 100 * time.Millisecond,

backoff_test.go backoff/backoff_test.gobackoff_test.go renamed to backoff/backoff_test.go

@@ -1,23 +1,23 @@
-package pgsql_test
+package backoff_test
 
 import (
 	"testing"
 	"time"
 
-	"github.com/acoshift/pgsql"
+	"github.com/acoshift/pgsql/backoff"
 )
 
 func TestExponentialBackoff(t *testing.T) {
 	t.Parallel()
 
-	config := pgsql.ExponentialBackoffConfig{
-		BackoffConfig: pgsql.BackoffConfig{
+	config := backoff.ExponentialBackoffConfig{
+		BackoffConfig: backoff.BackoffConfig{
 			BaseDelay: 10 * time.Millisecond,
 			MaxDelay:  1 * time.Second,
 		},
 		Multiplier: 2.0,
 	}
-	backoff := pgsql.NewExponentialBackoff(config)
+	backoff := backoff.NewExponentialBackoff(config)
 
 	// Test exponential growth
 	delays := []time.Duration{}
@@ -45,15 +45,15 @@ func TestExponentialBackoff(t *testing.T) {
 func TestExponentialBackoffWithFullJitter(t *testing.T) {
 	t.Parallel()
 
-	config := pgsql.ExponentialBackoffConfig{
-		BackoffConfig: pgsql.BackoffConfig{
+	config := backoff.ExponentialBackoffConfig{
+		BackoffConfig: backoff.BackoffConfig{
 			BaseDelay: 100 * time.Millisecond,
 			MaxDelay:  1 * time.Second,
 		},
 		Multiplier: 2.0,
-		JitterType: pgsql.FullJitter,
+		JitterType: backoff.FullJitter,
 	}
-	backoff := pgsql.NewExponentialBackoff(config)
+	backoff := backoff.NewExponentialBackoff(config)
 
 	// Test that jitter introduces randomness
 	var delays []time.Duration
@@ -86,15 +86,15 @@ func TestExponentialBackoffWithFullJitter(t *testing.T) {
 func TestExponentialBackoffWithEqualJitter(t *testing.T) {
 	t.Parallel()
 
-	config := pgsql.ExponentialBackoffConfig{
-		BackoffConfig: pgsql.BackoffConfig{
+	config := backoff.ExponentialBackoffConfig{
+		BackoffConfig: backoff.BackoffConfig{
 			BaseDelay: 100 * time.Millisecond,
 			MaxDelay:  1 * time.Second,
 		},
 		Multiplier: 2.0,
-		JitterType: pgsql.EqualJitter,
+		JitterType: backoff.EqualJitter,
 	}
-	backoff := pgsql.NewExponentialBackoff(config)
+	backoff := backoff.NewExponentialBackoff(config)
 
 	delay := backoff(2)
 
@@ -116,14 +116,14 @@ func TestExponentialBackoffWithEqualJitter(t *testing.T) {
 func TestLinearBackoff(t *testing.T) {
 	t.Parallel()
 
-	config := pgsql.LinearBackoffConfig{
-		BackoffConfig: pgsql.BackoffConfig{
+	config := backoff.LinearBackoffConfig{
+		BackoffConfig: backoff.BackoffConfig{
 			BaseDelay: 100 * time.Millisecond,
 			MaxDelay:  1 * time.Second,
 		},
 		Increment: 100 * time.Millisecond,
 	}
-	backoff := pgsql.NewLinearBackoff(config)
+	backoff := backoff.NewLinearBackoff(config)
 
 	// Test linear growth
 	delays := []time.Duration{}