Versions in this module Expand all Collapse all v0 v0.2.1 Mar 13, 2026 Changes in this version + var ErrAlreadyCompleted = errors.New("dureq: run already completed") + func CheckpointTx(ctx context.Context, tx *sql.Tx, step string, data []byte) error + func CompleteTx(ctx context.Context, tx *sql.Tx) error + func EnsureTable(ctx context.Context, db *sql.DB) error + func FailTx(ctx context.Context, tx *sql.Tx, err error) error + func IsCheckpointed(ctx context.Context, db *sql.DB, step string) (bool, []byte, error) + func IsCompleted(ctx context.Context, db *sql.DB) (bool, error)
Go to main page