Trait WorkerClient
Source pub trait WorkerClient {
Show 18 methods
// Required methods
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 get_files<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
component_id: &'life1 Uuid,
worker_name: &'life2 str,
file_name: &'life3 str,
) -> Pin<Box<dyn Future<Output = Result<GetFilesResponse, Error<WorkerError>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: '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 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 get_file_content<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
component_id: &'life1 Uuid,
worker_name: &'life2 str,
file_name: &'life3 str,
) -> Pin<Box<dyn Future<Output = Result<Bytes, Error<WorkerError>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait;
fn cancel_invocation<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
component_id: &'life1 Uuid,
worker_name: &'life2 str,
idempotency_key: &'life3 str,
) -> Pin<Box<dyn Future<Output = Result<CancelInvocationResponse, Error<WorkerError>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait;
fn activate_plugin<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
component_id: &'life1 Uuid,
worker_name: &'life2 str,
plugin_installation_id: &'life3 Uuid,
) -> Pin<Box<dyn Future<Output = Result<ActivatePluginResponse, Error<WorkerError>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait;
fn get_oplog<'life0, 'life1, 'life2, 'life3, 'life4, 'async_trait>(
&'life0 self,
component_id: &'life1 Uuid,
worker_name: &'life2 str,
from: Option<u64>,
count: u64,
cursor: Option<&'life3 OplogCursor>,
query: Option<&'life4 str>,
) -> Pin<Box<dyn Future<Output = Result<GetOplogResponse, 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 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 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;
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 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 revert_worker<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
component_id: &'life1 Uuid,
worker_name: &'life2 str,
value: &'life3 RevertWorkerTarget,
) -> Pin<Box<dyn Future<Output = Result<RevertWorkerResponse, Error<WorkerError>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: 'async_trait;
fn deactivate_plugin<'life0, 'life1, 'life2, 'life3, 'async_trait>(
&'life0 self,
component_id: &'life1 Uuid,
worker_name: &'life2 str,
plugin_installation_id: &'life3 Uuid,
) -> Pin<Box<dyn Future<Output = Result<DeactivatePluginResponse, Error<WorkerError>>> + Send + 'async_trait>>
where Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
'life3: '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;