Struct TaskRegistry 

pub struct TaskRegistry { /* private fields */ }

Registry mapping task names to type-erased handlers.

Implementations

impl TaskRegistry

pub fn new() -> TaskRegistry

pub fn register<T>(&mut self)

where T: Task,

Register a task type.

pub fn get( &self, name: &str, ) -> Option<&Arc<dyn Fn(Value, Arc<TaskContext>) -> Pin<Box<dyn Future<Output = Result<Value, KojinError>> + Send>> + Sync + Send>>

Look up a handler by task name.

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

Check if a task is registered.

pub async fn dispatch( &self, name: &str, payload: Value, ctx: Arc<TaskContext>, ) -> Result<Value, KojinError>

Execute a task by name with the given payload.

Trait Implementations

impl Clone for TaskRegistry

fn clone(&self) -> TaskRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for TaskRegistry

fn default() -> TaskRegistry

Returns the “default value” for a type.