Struct WorkerClientLive

pub struct WorkerClientLive {
    pub context: Context,
}

Fields

context: Context

Trait Implementations

impl WorkerClient for WorkerClientLive

fn get_workers_metadata<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, filter: Option<&'life2 [String]>, cursor: Option<&'life3 str>, count: Option<u64>, precise: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<WorkersMetadataResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn launch_new_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, value: &'life2 WorkerCreationRequest, ) -> Pin<Box<dyn Future<Output = Result<WorkerCreationResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn get_worker_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<WorkerMetadata, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn delete_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<DeleteWorkerResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn invoke_and_await_function_without_name<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, idempotency_key: Option<&'life2 str>, function: &'life3 str, value: &'life4 InvokeParameters, ) -> Pin<Box<dyn Future<Output = Result<InvokeResult, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn invoke_and_await_function<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, idempotency_key: Option<&'life3 str>, function: &'life4 str, value: &'life5 InvokeParameters, ) -> Pin<Box<dyn Future<Output = Result<InvokeResult, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

fn invoke_function_without_name<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, idempotency_key: Option<&'life2 str>, function: &'life3 str, value: &'life4 InvokeParameters, ) -> Pin<Box<dyn Future<Output = Result<InvokeResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait,

fn invoke_function<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, idempotency_key: Option<&'life3 str>, function: &'life4 str, value: &'life5 InvokeParameters, ) -> Pin<Box<dyn Future<Output = Result<InvokeResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait, 'life4: 'async_trait, 'life5: 'async_trait,

fn complete_promise<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, value: &'life3 CompleteParameters, ) -> Pin<Box<dyn Future<Output = Result<bool, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn interrupt_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, recovery_immediately: Option<bool>, ) -> Pin<Box<dyn Future<Output = Result<InterruptResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn find_workers_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, value: &'life2 WorkersMetadataRequest, ) -> Pin<Box<dyn Future<Output = Result<WorkersMetadataResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn resume_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<ResumeResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn update_worker<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, component_id: &'life1 Uuid, worker_name: &'life2 str, value: &'life3 UpdateWorkerRequest, ) -> Pin<Box<dyn Future<Output = Result<UpdateWorkerResponse, Error<WorkerError>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,