From 387013178f0da65c4462d38b3aaf55db089c3ab1 Mon Sep 17 00:00:00 2001 From: Wil Simpson Date: Tue, 17 Dec 2024 15:40:56 -0500 Subject: [PATCH] bug: pgx migrater conn made public --- pkg/repository/pgx.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/pkg/repository/pgx.go b/pkg/repository/pgx.go index 1220538..bb0462d 100644 --- a/pkg/repository/pgx.go +++ b/pkg/repository/pgx.go @@ -17,7 +17,7 @@ import ( type PgxMigrater struct { migrate *migrate.Migrate - conn *pgxpool.Pool + Conn *pgxpool.Pool } func NewPgxMigrater(ctx context.Context, pgpoolUrl string, migrationPath string) (*PgxMigrater, error) { @@ -33,19 +33,19 @@ func NewPgxMigrater(ctx context.Context, pgpoolUrl string, migrationPath string) return nil } - migrater.conn, err = pgxpool.NewWithConfig(context.Background(), pgConfig) + migrater.Conn, err = pgxpool.NewWithConfig(context.Background(), pgConfig) if err != nil { return nil, fmt.Errorf("connecting pool: %w", err) } err = backoff.Retry(func() error { - return migrater.conn.Ping(ctx) + return migrater.Conn.Ping(ctx) }, backoff.NewExponentialBackOff()) if err != nil { return nil, fmt.Errorf("pg pool not available: %w", err) } - driver, err := migratepgx.WithInstance(stdlib.OpenDBFromPool(migrater.conn), &migratepgx.Config{}) + driver, err := migratepgx.WithInstance(stdlib.OpenDBFromPool(migrater.Conn), &migratepgx.Config{}) if err != nil { return nil, fmt.Errorf("creating migrate driver: %w", err) }