asynq

package
v0.27.0-rc.3 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 31, 2026 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient

func NewClient(redisURI string) (worker.Client, error)

func NewServer

func NewServer(redisURI string, opts ...ServerOption) worker.Server

func Unique added in v0.17.2

func Unique() worker.CronjobOption

Unique configures a cron job to prevent concurrent processing. When enabled, the job will not be enqueued or executed again until it completes or the timeout specified in `SHELLHUB_ASYNQ_UNIQUENESS_TIMEOUT` is reached.

Types

type ServerOption

type ServerOption func(s *server) error

func UniquenessTimeout added in v0.17.2

func UniquenessTimeout(timeout int) ServerOption

UniquenessTimeout defines the maximum duration, in hours, for which a unique job remains locked in the queue. If the job does not complete within this timeout, the lock is released, allowing a new instance of the job to be enqueued and executed.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL