Documentation
¶
Overview ¶
Package postgres implements the storage-owned transactional ledger.
Index ¶
- Variables
- type CustodyRepository
- type Repository
- func (r *Repository) AcknowledgeEvent(ctx context.Context, id string) error
- func (r *Repository) CheckRuntime(ctx context.Context) error
- func (r *Repository) Claim(ctx context.Context, owner string, now time.Time, lease time.Duration) (storage.Job, error)
- func (r *Repository) PendingEvents(ctx context.Context, limit int) ([]storage.Event, error)
- func (r *Repository) Transaction(ctx context.Context, f func(storage.Transaction) error) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Schema string
Functions ¶
This section is empty.
Types ¶
type CustodyRepository ¶
type CustodyRepository struct{ Repository *Repository }
CustodyRepository shares only storage-owned tables and its append-only audit. A short registry lock bounds enrollment and serializes account claims. Network work is deliberately outside these transactions.
func (*CustodyRepository) Transaction ¶
type Repository ¶
func (*Repository) AcknowledgeEvent ¶
func (r *Repository) AcknowledgeEvent(ctx context.Context, id string) error
func (*Repository) CheckRuntime ¶
func (r *Repository) CheckRuntime(ctx context.Context) error
CheckRuntime rejects migration/admin identities and missing schema grants. It does not create schemas, change permissions, or inspect another module.
func (*Repository) PendingEvents ¶
func (*Repository) Transaction ¶
func (r *Repository) Transaction(ctx context.Context, f func(storage.Transaction) error) error
Source Files
Click to show internal directories.
Click to hide internal directories.