pgdb

func BackfillIntentTxid ¶ added in v0.9.0

func BackfillIntentTxid(ctx context.Context, dbh *sql.DB) error

func NewAssetRepository ¶ added in v0.9.0

func NewAssetRepository(config ...interface{}) (domain.AssetRepository, error)

func NewConvictionRepository ¶ added in v0.8.0

func NewConvictionRepository(config ...interface{}) (domain.ConvictionRepository, error)

func NewEventRepository ¶

func NewEventRepository(config ...interface{}) (domain.EventRepository, error)

func NewOffchainTxRepository ¶

func NewOffchainTxRepository(config ...interface{}) (domain.OffchainTxRepository, error)

func NewRoundRepository ¶

func NewRoundRepository(config ...interface{}) (domain.RoundRepository, error)

func NewSettingsRepository ¶ added in v0.9.9

func NewSettingsRepository(config ...interface{}) (domain.SettingsRepository, error)

func NewVtxoRepository ¶

func NewVtxoRepository(config ...interface{}) (domain.VtxoRepository, error)

func OpenDb ¶

func OpenDb(dsn string, autoCreate bool, opts ...Option) (*sql.DB, error)

OpenDb opens a connection with the DB.

By default, it uses sensible connection pool settings. These can be optionally overridden by providing a WithConnectionConfig option.

If the operation fails when trying to establish a connection and the `autoCreate` flag is set to true, OpenDb will try to create the database specified in the DSN.

func SeedSettings ¶ added in v0.9.9

func SeedSettings(ctx context.Context, db *sql.DB, defaults domain.Settings) (err error)

SeedSettings seeds the singleton settings row from the config-built defaults on first boot, carrying over any legacy intent_fees / scheduled_session rows, then deletes those legacy rows. It runs at most once: after the settings row exists it returns immediately without touching anything (so it never clobbers admin changes).

Everything runs in one raw transaction so a crash rolls back cleanly, leaving the legacy data intact for the next boot. The write goes through the generated UpsertSettings (not the repo's public Upsert) to deliberately bypass the repo's update dispatch and settings_history audit — this is init, not a user change.