Crate smelter_job_manager
source ·Expand description
Manage and run jobs for Smelter
Structs§
- A job in the system.
- The JobManager holds state and behavior that is shared between multiple jobs.
- Receive the results of finished tasks for a stage.
- A channel that can send new tasks into a job stage. This type can be cheaply Cloned to use it from multiple places. Say, consuming finished tasks from the stage and adding new jobs to it concurrently from different places. Drop this object or call JobStageTaskSender::finish to signify that no more tasks will be added to the stage.
- A wrapper around StatusCollector that only sends log messages
- Customization for the behavior of the job scheduler
- A stringified error copied from a worker’s output.
- An error that occurred in a job stage
- Collects status messages into a buffer which can be drained on command
- A channel that can be used to send status updates from the job manager
- Verbosity levels for printing status fields
- A formatter for a StatusUpdateData with custom levels of Verbosity for each field
- A task status update
- A formatter for a StatusUpdateItem with custom levels of Verbosity for each field in the StatusUpdateData
- Information about a spawned task
- Information about a successful task
- The ID for a subtask, which uniquely identifies it within a [Job].
- A task definition, along with the output that resulted from running it.
- An error that occurred in a subtask
Enums§
- When to rerun tasks that may be stalled.
- Types of status updates
- An error indicating that a task failed in some way.
- Verbosity levels for printing status fields
Traits§
- A trait representing a spawned task in the system. Task spawners should return a structure that implements this trait.
- A definition of a subtask.