dbunique

Sep 23, 2024

Changes in this version

+ func UniqueBitmaskToStates(mask byte) []rivertype.JobState

+ func UniqueKey(timeGen baseservice.TimeGenerator, uniqueOpts *UniqueOpts, ...) ([]byte, error)

+ func UniqueStatesToBitmask(states []rivertype.JobState) byte

type UniqueOpts

+ ExcludeKind bool

+ func (o *UniqueOpts) StateBitmask() byte

Feb 29, 2024

Changes in this version

+ type JobInsertResult struct

+ Job *rivertype.JobRow

+ UniqueSkippedAsDuplicate bool

+ type UniqueInserter struct

+ AdvisoryLockPrefix int32

+ func (i *UniqueInserter) JobInsert(ctx context.Context, exec riverdriver.Executor, ...) (*JobInsertResult, error)

+ type UniqueOpts struct

+ ByArgs bool

+ ByPeriod time.Duration

+ ByQueue bool

+ ByState []rivertype.JobState

+ func (o *UniqueOpts) IsEmpty() bool