dbunique

Documentation

Index

• func UniqueBitmaskToStates(mask byte) []rivertype.JobState
• func UniqueKey(timeGen baseservice.TimeGenerator, uniqueOpts *UniqueOpts, ...) ([]byte, error)
• func UniqueStatesToBitmask(states []rivertype.JobState) byte
• type UniqueInserter
  • func (i *UniqueInserter) JobInsert(ctx context.Context, exec riverdriver.Executor, ...) (*riverdriver.JobInsertFastResult, error)
• type UniqueOpts
  • func (o *UniqueOpts) IsEmpty() bool
  • func (o *UniqueOpts) StateBitmask() byte

Functions

func UniqueBitmaskToStates

func UniqueBitmaskToStates(mask byte) []rivertype.JobState

func UniqueKey

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

func UniqueStatesToBitmask

func UniqueStatesToBitmask(states []rivertype.JobState) byte

Types

type UniqueInserter

type UniqueInserter struct {
	baseservice.BaseService
	AdvisoryLockPrefix int32
}

func (*UniqueInserter) JobInsert

func (i *UniqueInserter) JobInsert(ctx context.Context, exec riverdriver.Executor, params *riverdriver.JobInsertFastParams, uniqueOpts *UniqueOpts) (*riverdriver.JobInsertFastResult, error)

type UniqueOpts

type UniqueOpts struct {
	ByArgs      bool
	ByPeriod    time.Duration
	ByQueue     bool
	ByState     []rivertype.JobState
	ExcludeKind bool
}

func (*UniqueOpts) IsEmpty

func (o *UniqueOpts) IsEmpty() bool

func (*UniqueOpts) StateBitmask

func (o *UniqueOpts) StateBitmask() byte