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