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 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 *rivertype.JobInsertParams) ([]byte, error)

func UniqueStatesToBitmask

func UniqueStatesToBitmask(states []rivertype.JobState) byte

Types

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