package
0.12.8
Repository: https://github.com/rotationalio/ensign.git
Documentation: pkg.go.dev

# Functions

No description provided by the author
No description provided by the author
Create a new task manager with the specified configuration.
Create a new scheduler that can schedule task futures.
Backoff strategy to use when retrying (default exponential backoff).
Specify a base context to be used as the parent context when the task is executed and on all subsequent retries.
Log a specific error if all retries failed under the provided context.
Log a specific error as WithError but using fmt.Errorf semantics to create the err.
Specify the number of times to retry a task when it returns an error (default 0).
Specify a timeout to add to the context before passing it into the task function.

# Variables

No description provided by the author
No description provided by the author
No description provided by the author
No description provided by the author

# Structs

Configures the radish task manager so that different processes can utilize different asynchronous task processing resources depending on process compute constraints.
Error keeps track of task failures and reports the failure context to Sentry.
Future is a task/timestamp tuple that acts as a scheduler entry for running the task as close to the timestamp as possible without running it before the given time.
Scheduler manages a list of future tasks and on or after the time that they are supposed to be scheduled, the scheduler sends the task on the out channel.
No description provided by the author
TaskManagers execute Tasks using a fixed number of workers that operate in their own go routines.

# Interfaces

Workers in the task manager handle Tasks which can hold state and other information needed by the task.

# Type aliases

Futures implements the sort.Sort interface and ensures that the list of future tasks is maintained in sorted order so that tasks are scheduled correctly.
Options configure the task beyond the input context allowing for retries or backoff delays in task processing when there are failures or other task-specific handling.
TaskFunc converts a function into a Task that can be queued or scheduled.