txman

type GenericHandler[T any] func(context.Context) (T, error)

type Handler = func(context.Context) error

type Postgres interface {
	BeginTx(ctx context.Context, opts pgx.TxOptions) (Tx, error)
}

type Tx interface {
	Commit(ctx context.Context) error
	Rollback(ctx context.Context) error
	Conn() *pgx.Conn
	CopyFrom(ctx context.Context, table pgx.Identifier, cols []string, src pgx.CopyFromSource) (int64, error)
	SendBatch(ctx context.Context, b *pgx.Batch) pgx.BatchResults
	LargeObjects() pgx.LargeObjects
	Prepare(ctx context.Context, name, sql string) (*pgconn.StatementDescription, error)
	Exec(ctx context.Context, sql string, args ...any) (pgconn.CommandTag, error)
	Query(ctx context.Context, sql string, args ...any) (pgx.Rows, error)
	QueryRow(ctx context.Context, sql string, args ...any) pgx.Row
	Begin(ctx context.Context) (pgx.Tx, error)
}

type TxConfig struct {
	IsoLevel   pgx.TxIsoLevel
	Retry      uint
	ReadOnly   bool
	MaxBackoff time.Duration
}

type TxManager interface {
	ReadCommitted(ctx context.Context, h Handler, opts ...TxOption) error
	RepeatableRead(ctx context.Context, h Handler, opts ...TxOption) error
	Serializable(ctx context.Context, h Handler, opts ...TxOption) error
	RunWithOpts(ctx context.Context, h Handler, opts []TxOption) error
}

type TxOption func(*TxConfig)