util

Documentation

Index

• func GetMetastate(ctx context.Context, db *pgxpool.Pool, tx pgx.Tx, key string) (string, error)
• func SetMetastate(db *pgxpool.Pool, tx pgx.Tx, key, jsonStrValue string) error
• func TxWithRetry(db *pgxpool.Pool, opts pgx.TxOptions, f func(pgx.Tx) error, log *log.Logger) error

Functions

func GetMetastate

func GetMetastate(ctx context.Context, db *pgxpool.Pool, tx pgx.Tx, key string) (string, error)

GetMetastate returns `idb.ErrorNotInitialized` if uninitialized. If `tx` is nil, it uses a normal query.

func SetMetastate

func SetMetastate(db *pgxpool.Pool, tx pgx.Tx, key, jsonStrValue string) error

SetMetastate sets metastate. If `tx` is nil, it uses a normal query.

func TxWithRetry

func TxWithRetry(db *pgxpool.Pool, opts pgx.TxOptions, f func(pgx.Tx) error, log *log.Logger) error

TxWithRetry is a helper function that retries the function `f` in case the database transaction in it fails due to a serialization error. `f` is provided a transaction created using `opts`. If `f` experiences a database error, this error must be included in `f`'s return error's chain, so that a serialization error can be detected.