pgx

package

v0.0.0-...-221a0dc Latest Latest Go to latest Published: Oct 18, 2023 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type PgxContext[P any, R any] struct {
	Tx      pgx.Tx
	Context context.Context
	// contains filtered or unexported fields
}

func NewPgxContext[P any, R any](outerTx pgx.Tx, tx pgx.Tx, context context.Context) *PgxContext[P, R]

func (ctx *PgxContext[P, R]) Fail(operation *a.TrackedOperation[P, R])

func (ctx *PgxContext[P, R]) Success(operation *a.TrackedOperation[P, R])

type PgxRepository[P any, R any] struct {
	// contains filtered or unexported fields
}

func NewPgxRepository[P any, R any](pool *pgxpool.Pool) *PgxRepository[P, R]

func (repo *PgxRepository[P, R]) DeleteExpired(status a.TrackedOperationStatus, count int) int64

func (repo *PgxRepository[P, R]) FailExpiredStillRunning(count int) int64

func (repo *PgxRepository[P, R]) FailTimedOutStillRunning(count int) int64

func (repo *PgxRepository[P, R]) FetchOrStart(operation a.Operation[P, R, *PgxContext[P, R]]) *a.TrackedOperation[P, R]

func (repo *PgxRepository[P, R]) NewSession(operation a.Operation[P, R, *PgxContext[P, R]]) *a.Session[P, R, *PgxContext[P, R]]