Trait golem_client::api::WorkerClient

source ·
pub trait WorkerClient {
    // Required methods
    fn get_workers_metadata<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        template_id: &'life1 Uuid,
        filter: Option<&'life2 [String]>,
        cursor: Option<u64>,
        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;
    fn launch_new_worker<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        template_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,
        template_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,
        template_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 get_invocation_key<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        template_id: &'life1 Uuid,
        worker_name: &'life2 str
    ) -> Pin<Box<dyn Future<Output = Result<InvocationKey, Error<WorkerError>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn invoke_and_await_function<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>(
        &'life0 self,
        template_id: &'life1 Uuid,
        worker_name: &'life2 str,
        invocation_key: &'life3 str,
        function: &'life4 str,
        calling_convention: Option<&'life5 CallingConvention>,
        value: &'life6 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,
             'life6: 'async_trait;
    fn invoke_function<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
        &'life0 self,
        template_id: &'life1 Uuid,
        worker_name: &'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 complete_promise<'life0, 'life1, 'life2, 'life3, 'async_trait>(
        &'life0 self,
        template_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,
        template_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,
        template_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,
        template_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;
}

Required Methods§

source

fn get_workers_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_id: &'life1 Uuid, filter: Option<&'life2 [String]>, cursor: Option<u64>, 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,

source

fn launch_new_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_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,

source

fn get_worker_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_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,

source

fn delete_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_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,

source

fn get_invocation_key<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_id: &'life1 Uuid, worker_name: &'life2 str ) -> Pin<Box<dyn Future<Output = Result<InvocationKey, Error<WorkerError>>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

source

fn invoke_and_await_function<'life0, 'life1, 'life2, 'life3, 'life4, 'life5, 'life6, 'async_trait>( &'life0 self, template_id: &'life1 Uuid, worker_name: &'life2 str, invocation_key: &'life3 str, function: &'life4 str, calling_convention: Option<&'life5 CallingConvention>, value: &'life6 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, 'life6: 'async_trait,

source

fn invoke_function<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>( &'life0 self, template_id: &'life1 Uuid, worker_name: &'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,

source

fn complete_promise<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, template_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,

source

fn interrupt_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_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,

source

fn find_workers_metadata<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_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,

source

fn resume_worker<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, template_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,

Implementors§