Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

Registry for mapping task names to their implementations

Implementations

impl TaskRegistry

pub fn new() -> Self

pub async fn register<T>(&self, task: T)

where T: Task + 'static,

Register a task type with the registry

pub async fn execute(&self, task: &SerializedTask) -> Result<Vec<u8>>

Execute a task by name

pub async fn has_task(&self, name: &str) -> bool

Check if a task is registered

pub async fn list_tasks(&self) -> Vec<String>

List all registered task names

Trait Implementations

impl Default for TaskRegistry

fn default() -> Self

Returns the “default value” for a type.