dbunique

Documentation

Index

• func UniqueKey(timeGen rivertype.TimeGenerator, uniqueOpts *UniqueOpts, ...) ([]byte, error)
• type UniqueOpts
  • func (o *UniqueOpts) IsEmpty() bool
  • func (o *UniqueOpts) StateBitmask() byte

Functions

func UniqueKey

func UniqueKey(timeGen rivertype.TimeGenerator, uniqueOpts *UniqueOpts, params *rivertype.JobInsertParams) ([]byte, error)

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