dbunique

Documentation

Index

• type JobInsertResult
• type UniqueInserter
  • func (i *UniqueInserter) JobInsert(ctx context.Context, exec riverdriver.Executor, ...) (*JobInsertResult, error)
• type UniqueOpts
  • func (o *UniqueOpts) IsEmpty() bool

Types

type JobInsertResult

type JobInsertResult struct {
	Job                      *rivertype.JobRow
	UniqueSkippedAsDuplicate bool
}

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) (*JobInsertResult, error)

type UniqueOpts

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

func (*UniqueOpts) IsEmpty

func (o *UniqueOpts) IsEmpty() bool