concurrent

Documentation

Index

• func Dequeuer(copt *DequeuerOptions) (work.DequeueMiddleware, work.HandleMiddleware)
• func LocalDequeuer(copt *LocalDequeuerOptions) (work.DequeueMiddleware, work.HandleMiddleware)
• type DequeuerOptions
• type LocalDequeuerOptions

Functions

func Dequeuer

func Dequeuer(copt *DequeuerOptions) (work.DequeueMiddleware, work.HandleMiddleware)

Dequeuer limits running job count from a queue.

func LocalDequeuer

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

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.