Module spawner

Source
Expand description

Spawns new jobs and handles cancellations

The job of the Spawner is to receive either a message indicating to execute a workflow or cancel a job. It executes each new job in a new Task allowing for parallelism so multiple jobs can be submitted to the async executor at once.

Structs§

Spawner
The Spawner struct contains the state required to create and cancel jobs

Enums§

SpawnerMsg
Different types of message that can be received by the Spawner

Functions§

cancel_msg
Creates SpawnerMsg::Cancel variant from &str
execute_msg
Creates SpawnerMsg::Execute variant from &str
spawner_channel
Create channel required for communication with the Spawner