postgres

package

v0.0.0-...-15b5bb4 Latest Latest Go to latest Published: Jul 19, 2026 License: MIT Imports: 10 Imported by: 0

Details

Package postgres provides a durable multi-process task-result cache.

This section is empty.

This section is empty.

This section is empty.

type Options struct {
	// Clock defaults to UTC time.Now and is injectable for deterministic TTL tests.
	Clock func() time.Time
}

Options controls PostgreSQL cache behavior.

type Store struct {
	// contains filtered or unexported fields
}

Store is a concurrency-safe PostgreSQL task cache.

func New(db *sql.DB, options ...Options) (*Store, error)

New constructs a Store over an existing database handle without taking ownership.

func Open(ctx context.Context, dsn string, options ...Options) (*Store, error)

Open opens a pgx database/sql handle, applies the schema, and returns an owning Store.

func (s *Store) Clear(ctx context.Context, namespaces []string) error

Clear implements cache.Store. Nil namespaces clears all rows.

func (s *Store) Close() error

Close closes only database handles owned by Open.

func (s *Store) Get(ctx context.Context, keys []cache.Key) (map[cache.Key][]byte, error)

Get implements cache.Store with lazy transactional expiry deletion.

func (s *Store) Set(ctx context.Context, items map[cache.Key]cache.Item) error

Set implements cache.Store as an atomic upsert transaction.

func (s *Store) Setup(ctx context.Context) error

Setup creates the cache schema under a transaction-scoped advisory lock.