Documentation
¶
Overview ¶
Package postgres owns contribution metadata and its independent runtime identity.
Index ¶
- Variables
- 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, worker string, now time.Time, lease time.Duration) (contribution.Job, error)
- func (r *Repository) PendingEvents(ctx context.Context, n int) ([]contribution.Event, error)
- func (r *Repository) Transaction(ctx context.Context, run func(contribution.Transaction) error) error
Constants ¶
This section is empty.
Variables ¶
View Source
var Schema string
Functions ¶
This section is empty.
Types ¶
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
func (*Repository) PendingEvents ¶
func (r *Repository) PendingEvents(ctx context.Context, n int) ([]contribution.Event, error)
func (*Repository) Transaction ¶
func (r *Repository) Transaction(ctx context.Context, run func(contribution.Transaction) error) error
Source Files
Click to show internal directories.
Click to hide internal directories.