psql

Documentation

Index

• Variables
• func CreatePooledConnection(ctx context.Context, uri string) (*pgxpool.Pool, error)
• type Postgres
  • func NewPostgres(dbPool *pgxpool.Pool, queue *river.Client[pgx.Tx]) Postgres
  • func (p Postgres) BeginTx(ctx context.Context) (pgx.Tx, error)
  • func (p Postgres) CommitTx(ctx context.Context, tx pgx.Tx) error
  • func (p Postgres) RollBackTx(ctx context.Context, tx pgx.Tx) error

Variables

var (
	ErrInternalDB = errors.New(
		"an error occurred that was not possible to recover from",
	)
	ErrBeginTx             = errors.New("could not begin transaction")
	ErrRollbackTx          = errors.New("could not rollback transaction")
	ErrCommitTx            = errors.New("could not commit transaction")
	ErrNoRowWithIdentifier = errors.New(
		"could not find requested row in database",
	)
)

var Migrations embed.FS

Functions

func CreatePooledConnection

func CreatePooledConnection(
	ctx context.Context,
	uri string,
) (*pgxpool.Pool, error)

Types

type Postgres

type Postgres struct {
	Pool  *pgxpool.Pool
	Queue *river.Client[pgx.Tx]
}

func NewPostgres

func NewPostgres(dbPool *pgxpool.Pool, queue *river.Client[pgx.Tx]) Postgres

func (Postgres) BeginTx

func (p Postgres) BeginTx(ctx context.Context) (pgx.Tx, error)

func (Postgres) CommitTx

func (p Postgres) CommitTx(ctx context.Context, tx pgx.Tx) error

func (Postgres) RollBackTx

func (p Postgres) RollBackTx(ctx context.Context, tx pgx.Tx) error