Struct TaskRegistry

pub struct TaskRegistry { /* private fields */ }

Task registry for mapping task names to executors

Implementations

impl TaskRegistry

pub fn new() -> Self

pub fn with_auto_registered() -> Result<Self, Box<dyn Error + Send + Sync>>

Create a new registry with all automatically registered tasks

pub fn with_auto_registered_and_config( config: Option<&AutoRegisterConfig>, ) -> Result<Self, Box<dyn Error + Send + Sync>>

Create a new registry with all automatically registered tasks and configuration

pub fn auto_register_tasks(&self) -> Result<(), Box<dyn Error + Send + Sync>>

Register all tasks that have been submitted via the inventory pattern

pub fn auto_register_tasks_with_config( &self, _config: Option<&AutoRegisterConfig>, ) -> Result<(), Box<dyn Error + Send + Sync>>

Register all tasks with optional configuration

pub fn register_with_name<T>( &self, task_name: &str, ) -> Result<(), Box<dyn Error + Send + Sync>>

where T: Task + 'static,

Register a task type with explicit name

pub async fn execute(&self, task_name: &str, payload: Vec<u8>) -> TaskResult

Execute a task by name

pub fn registered_tasks(&self) -> Vec<String>

Get list of registered task names

Trait Implementations

impl Default for TaskRegistry

fn default() -> Self

Returns the “default value” for a type.