unique

Documentation

Index

• Variables
• func Enqueuer(eopt *EnqueuerOptions) work.EnqueueMiddleware
• type EnqueuerOptions
• type Func

Variables

var (
	// ErrDedupDuration is returned when UniqueFunc returns a non-positive duration.
	// The dedup key will expire too soon in redis.
	ErrDedupDuration = errors.New("work: unique duration should be > 0")
)

Functions

func Enqueuer

func Enqueuer(eopt *EnqueuerOptions) work.EnqueueMiddleware

Enqueuer uses UniqueFunc to ensure job uniqueness in a period.

Types

type EnqueuerOptions

type EnqueuerOptions struct {
	Client redis.UniversalClient
	// If returned []byte is nil, uniqueness check is bypassed.
	// Returned time.Duration controls how long the unique key exists.
	UniqueFunc Func
}

EnqueuerOptions defines job unique key generation.

type Func

type Func func(*work.Job, *work.EnqueueOptions) ([]byte, time.Duration, error)

Func defines job uniqueness.