Struct AsyncRegistry 

pub struct AsyncRegistry { /* private fields */ }

Implementations

impl AsyncRegistry

pub fn new() -> Self

pub fn register_operation_capability<C, F, Fut>( &mut self, capability: CapabilityType<C>, handler: F, )

where C: OperationCapability, F: Fn(C::Request, CapabilityCtx) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<C::Ok, C::Err>> + Send + 'static,

pub fn register_job<J, F, Fut>(&mut self, job: JobRef<J>, handler: F)

where J: JobSpec, F: Fn(J::Request, JobCtx) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<J::Ok, J::Err>> + Send + 'static,

pub fn register_service<S, F, Fut>( &mut self, service: ServiceType<S>, starter: F, )

where S: ServiceSpec + 'static, F: Fn(S::Config, ServiceCtx<S>) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<Box<dyn ServiceRunner<S>>, S::StartErr>> + Send + 'static,

pub fn spawn_job( &self, job_name: &str, req_id: u64, payload: Vec<u8>, on_ok: Option<ActionEnvelope>, on_err: Option<ActionEnvelope>, resource: Option<ResourceExecutionContext>, tx: &Sender<AsyncMessage>, wake: WakeFn, ) -> bool

pub fn spawn_capability( &self, capability_name: &str, req_id: u64, payload: Vec<u8>, on_ok: Option<ActionEnvelope>, on_err: Option<ActionEnvelope>, resource: Option<ResourceExecutionContext>, tx: &Sender<AsyncMessage>, wake: WakeFn, ) -> bool

pub fn spawn_service( &self, service_name: &str, slot_key: &str, instance_id: u64, config: Vec<u8>, resource: Option<ResourceExecutionContext>, tx: &Sender<AsyncMessage>, wake: WakeFn, ) -> Option<RunningServiceHandle>

Trait Implementations

impl Default for AsyncRegistry

fn default() -> Self

Returns the “default value” for a type.