Skip to content

Commit

Permalink
bug: pgx migrater conn made public
Browse files Browse the repository at this point in the history
  • Loading branch information
Wil Simpson committed Dec 17, 2024
1 parent fdd1f4f commit 3870131
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions pkg/repository/pgx.go
Original file line number Diff line number Diff line change
Expand Up @@ -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) {
Expand All @@ -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)
}
Expand Down

0 comments on commit 3870131

Please sign in to comment.