Struct ExternalTaskApiClient 

pub struct ExternalTaskApiClient { /* private fields */ }

Implementations

impl ExternalTaskApiClient

pub fn new(configuration: Rc<Configuration>) -> ExternalTaskApiClient

Trait Implementations

impl ExternalTaskApi for ExternalTaskApiClient

fn complete_external_task_resource( &self, id: &str, complete_external_task_dto: Option<CompleteExternalTaskDto>, ) -> Result<(), Error>

fn extend_lock( &self, id: &str, extend_lock_on_external_task_dto: Option<ExtendLockOnExternalTaskDto>, ) -> Result<(), Error>

fn fetch_and_lock( &self, fetch_external_tasks_dto: Option<FetchExternalTasksDto>, ) -> Result<Vec<LockedExternalTaskDto>, Error>

fn get_external_task(&self, id: &str) -> Result<ExternalTaskDto, Error>

fn get_external_task_error_details(&self, id: &str) -> Result<String, Error>

fn get_external_tasks( &self, external_task_id: Option<&str>, external_task_id_in: Option<&str>, topic_name: Option<&str>, worker_id: Option<&str>, locked: Option<bool>, not_locked: Option<bool>, with_retries_left: Option<bool>, no_retries_left: Option<bool>, lock_expiration_after: Option<String>, lock_expiration_before: Option<String>, activity_id: Option<&str>, activity_id_in: Option<&str>, execution_id: Option<&str>, process_instance_id: Option<&str>, process_instance_id_in: Option<&str>, process_definition_id: Option<&str>, tenant_id_in: Option<&str>, active: Option<bool>, suspended: Option<bool>, priority_higher_than_or_equals: Option<i64>, priority_lower_than_or_equals: Option<i64>, sort_by: Option<&str>, sort_order: Option<&str>, first_result: Option<i32>, max_results: Option<i32>, ) -> Result<Vec<ExternalTaskDto>, Error>

fn get_external_tasks_count( &self, external_task_id: Option<&str>, external_task_id_in: Option<&str>, topic_name: Option<&str>, worker_id: Option<&str>, locked: Option<bool>, not_locked: Option<bool>, with_retries_left: Option<bool>, no_retries_left: Option<bool>, lock_expiration_after: Option<String>, lock_expiration_before: Option<String>, activity_id: Option<&str>, activity_id_in: Option<&str>, execution_id: Option<&str>, process_instance_id: Option<&str>, process_instance_id_in: Option<&str>, process_definition_id: Option<&str>, tenant_id_in: Option<&str>, active: Option<bool>, suspended: Option<bool>, priority_higher_than_or_equals: Option<i64>, priority_lower_than_or_equals: Option<i64>, ) -> Result<CountResultDto, Error>

fn get_topic_names( &self, with_locked_tasks: Option<bool>, with_unlocked_tasks: Option<bool>, with_retries_left: Option<bool>, ) -> Result<Vec<String>, Error>

fn handle_external_task_bpmn_error( &self, id: &str, external_task_bpmn_error: Option<ExternalTaskBpmnError>, ) -> Result<(), Error>

fn handle_failure( &self, id: &str, external_task_failure_dto: Option<ExternalTaskFailureDto>, ) -> Result<(), Error>

fn query_external_tasks( &self, first_result: Option<i32>, max_results: Option<i32>, external_task_query_dto: Option<ExternalTaskQueryDto>, ) -> Result<Vec<ExternalTaskDto>, Error>

fn query_external_tasks_count( &self, external_task_query_dto: Option<ExternalTaskQueryDto>, ) -> Result<CountResultDto, Error>

fn set_external_task_resource_priority( &self, id: &str, priority_dto: Option<PriorityDto>, ) -> Result<(), Error>

fn set_external_task_resource_retries( &self, id: &str, retries_dto: Option<RetriesDto>, ) -> Result<(), Error>

fn set_external_task_retries( &self, set_retries_for_external_tasks_dto: Option<SetRetriesForExternalTasksDto>, ) -> Result<(), Error>

fn set_external_task_retries_async_operation( &self, set_retries_for_external_tasks_dto: Option<SetRetriesForExternalTasksDto>, ) -> Result<BatchDto, Error>

fn unlock(&self, id: &str) -> Result<(), Error>