concurrent

Documentation

Index

• func Dequeuer(copt *DequeuerOptions) work.DequeueMiddleware
• type DequeuerOptions

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.UniversalClient
	Max    int64
	// contains filtered or unexported fields
}

DequeuerOptions defines how many jobs in the same queue can be running at the same time.