postgres

package

v0.0.0-...-a70fa55 Latest Latest Go to latest Published: Oct 29, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

Package postgres owns the resources schema and data access identity.

This section is empty.

View Source

var Schema string

func Migrate(ctx context.Context, db *sql.DB) error

Migrate uses a separate migration identity. Initial categories are ordinary persisted settings; repeated migrations never overwrite operator changes.

type Repository struct{ DB *sql.DB }

func (r *Repository) AcknowledgeEvent(ctx context.Context, id string) error

func (r *Repository) CheckRuntime(ctx context.Context) error

CheckRuntime rejects migration credentials and cross-module access at startup.

func (r *Repository) Claim(ctx context.Context, worker string, now time.Time, lease time.Duration) (resources.Job, error)

func (r *Repository) PendingEvents(ctx context.Context, n int) ([]resources.Event, error)

func (r *Repository) PrunePackages(ctx context.Context, now time.Time, n int) error

PrunePackages removes only expired selection snapshots, never business records or idempotency receipts.

func (r *Repository) Transaction(ctx context.Context, run func(resources.Transaction) error) error