database

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 21, 2026 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AdvisoryTransactionLock added in v0.4.0 

func AdvisoryTransactionLock(ctx context.Context, executor CommandExecutor, key string) error

AdvisoryTransactionLock obtains a transaction-scoped PostgreSQL advisory lock for a stable application key. The caller must execute it inside an active transaction; PostgreSQL releases the lock when that transaction ends.

func InTransaction added in v0.2.0 

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 

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 

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

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

Types

type CommandExecutor added in v0.4.0 

type CommandExecutor interface {
	Exec(context.Context, string, ...any) (pgconn.CommandTag, error)
}

CommandExecutor is implemented by pgx connections, pools and transactions.

type Config 

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

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

func LoadConfig 

func LoadConfig() (Config, error)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.