Struct camunda_client::models::fetch_external_tasks_dto::FetchExternalTasksDto

pub struct FetchExternalTasksDto {
    pub worker_id: String,
    pub max_tasks: Option<i32>,
    pub use_priority: Option<bool>,
    pub async_response_timeout: Option<i64>,
    pub topics: Option<Vec<FetchExternalTaskTopicDto>>,
}

Fields

worker_id: String

Mandatory. The id of the worker on which behalf tasks are fetched. The returned tasks are locked for that worker and can only be completed when providing the same worker id.

max_tasks: Option<i32>

Mandatory. The maximum number of tasks to return.

use_priority: Option<bool>

A boolean value, which indicates whether the task should be fetched based on its priority or arbitrarily.

async_response_timeout: Option<i64>

The Long Polling timeout in milliseconds. Note: The value cannot be set larger than 1.800.000 milliseconds (corresponds to 30 minutes).

topics: Option<Vec<FetchExternalTaskTopicDto>>

A JSON array of topic objects for which external tasks should be fetched. The returned tasks may be arbitrarily distributed among these topics. Each topic object has the following properties:

Implementations

impl FetchExternalTasksDto

pub fn new(worker_id: String, max_tasks: Option<i32>) -> FetchExternalTasksDto

Trait Implementations

impl Clone for FetchExternalTasksDto

fn clone(&self) -> FetchExternalTasksDto

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for FetchExternalTasksDto

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FetchExternalTasksDto

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<FetchExternalTasksDto> for FetchExternalTasksDto

fn eq(&self, other: &FetchExternalTasksDto) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &FetchExternalTasksDto) -> bool

This method tests for !=.

impl Serialize for FetchExternalTasksDto

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error> where
    __S: Serializer, 

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for FetchExternalTasksDto