Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Dequeuer ¶
func Dequeuer(copt *DequeuerOptions) (work.DequeueMiddleware, work.HandleMiddleware)
Dequeuer limits running job count from a queue.
func LocalDequeuer ¶ added in v0.2.4
func LocalDequeuer(copt *LocalDequeuerOptions) (work.DequeueMiddleware, work.HandleMiddleware)
LocalDequeuer limits running job count from the same process.
Types ¶
type DequeuerOptions ¶
type DequeuerOptions struct {
Client redis.UniversalClient
Max int64
// contains filtered or unexported fields
}
DequeuerOptions defines how many jobs in the same queue can be running at the same time.
type LocalDequeuerOptions ¶ added in v0.2.4
type LocalDequeuerOptions struct {
Max int64
// contains filtered or unexported fields
}
LocalDequeuerOptions defines how many jobs on the same process can be running at the same time.
Source Files
Click to show internal directories.
Click to hide internal directories.