# Packages
No description provided by the author
# Functions
NewClient creates a new Client that uses the pgx pool, logger/Logger, and default exponential backoff.
NewWorkerPool creates a new WorkerPool with count workers using the Client c, configured with default poll interval of 5 seconds and default poll strategy of priority poll strategy.
WithClientBackoff sets backoff implementation that will be applied to errored jobs within current client session.
WithClientID sets client ID for easier identification in logs.
WithClientLogger sets Logger implementation to client.
WithPoolHooksJobDone calls WithWorkerHooksJobDone for every worker in the pool.
WithPoolHooksJobLocked calls WithWorkerHooksJobLocked for every worker in the pool.
WithPoolHooksUnknownJobType calls WithWorkerHooksUnknownJobType for every worker in the pool.
WithPoolID sets worker pool ID for easier identification in logs.
WithPoolLogger sets Logger implementation to worker pool.
No description provided by the author
WithPoolPollInterval overrides default poll interval with the given value.
WithPoolPollStrategy overrides default poll strategy with given value.
No description provided by the author
WithPoolQueue overrides default worker queue name with the given value.
# Constants
No description provided by the author
PriorityPollStrategy cares about the priority first to lock top priority jobs first even if there are availableones that should be executed earlier but with lower priority.
RunAtPollStrategy cares about the scheduled time first to lock earliest to execute jobs first even if there are ones with a higher priority scheduled to a later time but already eligible for execution.
No description provided by the author
# Variables
No description provided by the author
No description provided by the author
By default, jobs are migrate to the gue_jobs_finished table after being performed.
By default, jobs are deleted from the gue_jobs table after being performed.
# Structs
Client is a Gue client that can add jobs to the queue and remove jobs from the queue.
No description provided by the author
No description provided by the author
GueJob corresponds to table gue_jobs as define above.
No description provided by the author
# Type aliases
Backoff is the interface for backoff implementation that will be used to reschedule errored jobs.
ClientOption defines a type that allows to set client properties during the build-time.
HookFunc is a function that may react to a Job lifecycle events.
Job is a single unit of work for Gue to perform.
No description provided by the author
PollStrategy determines how the DB is queried for the next job to work on.
No description provided by the author
WorkerPoolOption defines a type that allows to set worker pool properties during the build-time.
WorkFunc is a function that performs a Job.
WorkMap is a map of Job names to WorkFuncs that are used to perform Jobs of a given type.