Versions in this module Expand all Collapse all v1 v1.0.1 Aug 8, 2022 v1.0.0 Aug 4, 2022 Changes in this version + const DefaultMaxBatchSize + var Name = "DBLocker" + type DBLocker struct + func New(dbURI string, opts ...Opt) (*DBLocker, error) + func (d *DBLocker) Close() error + func (d *DBLocker) Lock(ctx xcontext.Context, jobID types.JobID, duration time.Duration, ...) error + func (d *DBLocker) RefreshLocks(ctx xcontext.Context, jobID types.JobID, duration time.Duration, ...) error + func (d *DBLocker) ResetAllLocks(ctx xcontext.Context) error + func (d *DBLocker) TryLock(ctx xcontext.Context, jobID types.JobID, duration time.Duration, ...) ([]string, error) + func (d *DBLocker) Unlock(ctx xcontext.Context, jobID types.JobID, targets []*target.Target) error + type Opt func(dblocker *DBLocker) + func WithClock(value clock.Clock) Opt + func WithDriverName(name string) Opt + func WithMaxBatchSize(value int) Opt
Go to main page