fix imports

retriever/postgresqlretriever/database.go

@@ -1,40 +1,40 @@
 package postgresqlretriever
 
 import (
-	"context"
-	"fmt"
-	"sync"
+    "context"
+    "fmt"
+    "sync"
 
-	"github.com/jackc/pgx/v5/pgxpool"
+    "github.com/jackc/pgx/v5/pgxpool"
 )
 
 var poolInstance *pgxpool.Pool
 var once sync.Once
-var poolErr error
+var errPool error
 
 // refCount tracks how many retrievers are currently using the pool.
 var refCount int
 var refCountMutex sync.Mutex
 
 func GetPool(ctx context.Context, uri string) (*pgxpool.Pool, error) {
 	// The sync.Once ensures that the inner function is executed only once,
 	// even if called by multiple goroutines concurrently.
 	once.Do(func() {
-		poolInstance, poolErr = pgxpool.New(ctx, uri)
-		if poolErr != nil {
-			poolErr = fmt.Errorf("failed to create connection pool: %w", poolErr)
+		poolInstance, errPool = pgxpool.New(ctx, uri)
+		if errPool != nil {
+			errPool = fmt.Errorf("failed to create connection pool: %w", errPool)
 			return
 		}
 
 		// Check connection immediately
 		if err := poolInstance.Ping(ctx); err != nil {
-			poolErr = fmt.Errorf("failed to ping database with new pool: %w", err)
+			errPool = fmt.Errorf("failed to ping database with new pool: %w", err)
 			// Don't close here, the pool remains valid for a retry connection
 		}
 	})
 
-	if poolErr != nil {
-		return nil, poolErr
+	if errPool != nil {
+		return nil, errPool
 	}
 
 	refCountMutex.Lock()
@@ -58,6 +58,6 @@
 		poolInstance = nil
 		// Reset sync.Once to allow re-initialization if needed
 		once = sync.Once{}
-		poolErr = nil
+		errPool = nil
 	}
 }

retriever/postgresqlretriever/retriever.go

@@ -1,15 +1,17 @@
 package postgresqlretriever
 
 import (
-	"context"
-	"encoding/json"
-	"fmt"
-	"github.com/jackc/pgx/v5"
-	"github.com/jackc/pgx/v5/pgxpool"
-	"github.com/thomaspoignant/go-feature-flag/retriever"
-	"github.com/thomaspoignant/go-feature-flag/utils"
-	"github.com/thomaspoignant/go-feature-flag/utils/fflog"
-	"log/slog"
+    "context"
+    "encoding/json"
+    "fmt"
+    "log/slog"
+
+    "github.com/jackc/pgx/v5"
+    "github.com/jackc/pgx/v5/pgxpool"
+
+    "github.com/thomaspoignant/go-feature-flag/retriever"
+    "github.com/thomaspoignant/go-feature-flag/utils"
+    "github.com/thomaspoignant/go-feature-flag/utils/fflog"
 )
 
 var defaultColumns = map[string]string{
@@ -66,7 +68,7 @@
 }
 
 // Shutdown closes the database connection.
 func (r *Retriever) Shutdown(ctx context.Context) error {
 	ReleasePool()
 	return nil
 }