Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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) (*rivertype.JobInsertResult, error)
Click to show internal directories.
Click to hide internal directories.