Struct HandlerRegistry 

pub struct HandlerRegistry { /* private fields */ }

Implementations

impl HandlerRegistry

pub fn new() -> Self

pub fn register<F, Fut>( &mut self, task_name: TaskName, handler_version: HandlerVersion, retry_policy: RetryPolicy, handler: F, ) -> bool

where F: Fn(Task) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, HandlerError>> + Send + 'static,

pub fn register_durable<F, Fut>( &mut self, task_name: TaskName, handler_version: HandlerVersion, retry_policy: RetryPolicy, handler: F, ) -> bool

where F: Fn(Task, TaskContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Value, HandlerError>> + Send + 'static,

pub fn capabilities(&self) -> Vec<(TaskName, HandlerVersion)>

Trait Implementations

impl Clone for HandlerRegistry

fn clone(&self) -> HandlerRegistry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for HandlerRegistry

fn default() -> HandlerRegistry

Returns the “default value” for a type.