package
0.0.0-20241114093836-1dfe8d6e4640
Repository: https://github.com/p40pmn/redis-queue.git
Documentation: pkg.go.dev
# Functions
NewRegistry returns a new Registry instance using redis for distributed synchronization.
# Constants
DefaultAckDeadline is the default number of seconds a job can wait to be acknowledged after being queued.
DefaultMaxExecutionTime is the default maximum duration (in seconds) allowed for a job or process to complete.
DefaultMaxWorker is the default maximum number of jobs that can be processed in parallel.
# Variables
ErrJobAlreadyAssigned indicates that the job is already assigned.
ErrJobAlreadyCompleted indicates that the job is already completed.
ErrJobAlreadyExistsOrSkipped indicates that the job is already exists or skipped.
ErrJobAlreadyProcessing indicates that the job is already being processed.
ErrJobNotFound indicates that the job is not found.
ErrJobNotInQueue indicates that the job is not in the queue.
ErrLockNotAcquired indicates that another instance is already acquiring the lock.
# Structs
No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author
Registry manages dynamic creation and reuse of Queue instances for different projects with distributed locking.
RegistryConfig is the configuration for the Registry.