Versions in this module Expand all Collapse all v0 v0.2.0 May 1, 2026 v0.1.0 Feb 22, 2026 Changes in this version + func EnsureSchema(ctx context.Context, pool *pgxpool.Pool) error + type EpochCache struct + func NewEpochCache(ctx context.Context, pool *pgxpool.Pool) (*EpochCache, error) + func (c *EpochCache) GetMaxEpochSeen(vaultID string) uint64 + func (c *EpochCache) SetMaxEpochSeen(vaultID string, epoch uint64) error + type Store struct + func NewRepository(pool *pgxpool.Pool) *Store + func NewRepositoryFromDSN(ctx context.Context, dsn string) (*Store, error) + func (s *Store) Batch(vaultID string, fn func(tx storage.BatchTx) error) error + func (s *Store) Close() + func (s *Store) Delete(vaultID, recordType, recordID string) error + func (s *Store) DeleteVault(vaultID string) error + func (s *Store) Get(vaultID, recordType, recordID string) (*storage.Envelope, error) + func (s *Store) List(vaultID, recordType string) ([]string, error) + func (s *Store) ListVaults() ([]string, error) + func (s *Store) Pool() *pgxpool.Pool + func (s *Store) Put(vaultID, recordType, recordID string, envelope *storage.Envelope) error + func (s *Store) PutCAS(vaultID, recordType, recordID string, expectedVersion uint64, ...) error
Go to main page