database

package

v0.3.0 Latest Latest Go to latest Published: Sep 6, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func InTransaction(
	ctx context.Context,
	pool *pgxpool.Pool,
	operation func(pgx.Tx) error,
) error

InTransaction runs operation in a transaction and automatically commits or rolls it back.

func NewPool(ctx context.Context, config Config) (*pgxpool.Pool, error)

NewPool creates a PostgreSQL connection pool and verifies that the database is available.

func OpenSQL(config Config) (*sql.DB, error)

OpenSQL creates a database/sql connection pool for migration tools.

type Config struct {
	// contains filtered or unexported fields
}

Config contains PostgreSQL connection settings loaded from the ProcessModule runtime environment.

func LoadConfig() (Config, error)

LoadConfig loads PostgreSQL connection settings from environment variables and reads the password from a secret file.