Documentation
¶
Index ¶
Constants ¶
View Source
const ( // AllQueuesString is a special string that can be used to indicate all // queues in some operations, particularly pause and resume. AllQueuesString = "*" MaxAttemptsDefault = 25 PriorityDefault = 1 QueueDefault = "default" )
These constants are made available in rivercommon so that they're accessible by internal packages, but the top-level river package re-exports them, and all user code must use that set instead.
Variables ¶
View Source
var ErrStop = errors.New("stop initiated")
ErrStop is a special error injected by the client into its fetch and work CancelCauseFuncs when it's stopping. It may be used by components for such cases like avoiding logging an error during a normal shutdown procedure.
Functions ¶
This section is empty.
Types ¶
type ContextKeyClient ¶ added in v0.12.0
type ContextKeyClient struct{}
Source Files
Click to show internal directories.
Click to hide internal directories.