Struct google_api_proto::google::cloud::integrations::v1alpha::TaskConfig

pub struct TaskConfig {

    pub task: String,
    pub task_id: String,
    pub parameters: BTreeMap<String, EventParameter>,
    pub failure_policy: Option<FailurePolicy>,
    pub synchronous_call_failure_policy: Option<FailurePolicy>,
    pub next_tasks: Vec<NextTask>,
    pub next_tasks_execution_policy: i32,
    pub task_execution_strategy: i32,
    pub display_name: String,
    pub success_policy: Option<SuccessPolicy>,
    pub json_validation_option: i32,
    pub description: String,
    pub task_template: String,
    pub error_catcher_id: String,
    pub external_task_type: i32,
    pub position: Option<Coordinate>,
}

The task configuration details. This is not the implementation of Task. There might be multiple TaskConfigs for the same Task.

Fields

task: String

Optional. The name for the task.

task_id: String

Required. The identifier of this task within its parent event config, specified by the client. This should be unique among all the tasks belong to the same event config. We use this field as the identifier to find next tasks (via field next_tasks.task_id).

parameters: BTreeMap<String, EventParameter>

Optional. The customized parameters the user can pass to this task.

failure_policy: Option<FailurePolicy>

Optional. Determines the number of times the task will be retried on failure and with what retry strategy. This is applicable for asynchronous calls to Eventbus alone (Post To Queue, Schedule etc.).

synchronous_call_failure_policy: Option<FailurePolicy>

Optional. Determines the number of times the task will be retried on failure and with what retry strategy. This is applicable for synchronous calls to Eventbus alone (Post).

next_tasks: Vec<NextTask>

Optional. The set of tasks that are next in line to be executed as per the execution graph defined for the parent event, specified by event_config_id. Each of these next tasks are executed only if the condition associated with them evaluates to true.

next_tasks_execution_policy: i32

Optional. The policy dictating the execution of the next set of tasks for the current task.

task_execution_strategy: i32

Optional. The policy dictating the execution strategy of this task.

display_name: String

Optional. User-provided label that is attached to this TaskConfig in the UI.

success_policy: Option<SuccessPolicy>

Optional. Determines what action to take upon successful task completion.

json_validation_option: i32

Optional. If set, overrides the option configured in the Task implementation class.

description: String

Optional. User-provided description intended to give additional business context about the task.

task_template: String

Optional. Used to define task-template name if task is of type task-template

error_catcher_id: String

Optional. Optional Error catcher id of the error catch flow which will be executed when execution error happens in the task

external_task_type: i32

Optional. External task type of the task

position: Option<Coordinate>

Optional. Informs the front-end application where to draw this error catcher config on the UI.

Implementations

impl TaskConfig

pub fn next_tasks_execution_policy(&self) -> NextTasksExecutionPolicy

Returns the enum value of next_tasks_execution_policy, or the default if the field is set to an invalid enum value.

pub fn set_next_tasks_execution_policy( &mut self, value: NextTasksExecutionPolicy, )

Sets next_tasks_execution_policy to the provided enum value.

pub fn task_execution_strategy(&self) -> TaskExecutionStrategy

Returns the enum value of task_execution_strategy, or the default if the field is set to an invalid enum value.

pub fn set_task_execution_strategy(&mut self, value: TaskExecutionStrategy)

Sets task_execution_strategy to the provided enum value.

pub fn json_validation_option(&self) -> JsonValidationOption

Returns the enum value of json_validation_option, or the default if the field is set to an invalid enum value.

pub fn set_json_validation_option(&mut self, value: JsonValidationOption)

Sets json_validation_option to the provided enum value.

pub fn external_task_type(&self) -> ExternalTaskType

Returns the enum value of external_task_type, or the default if the field is set to an invalid enum value.

pub fn set_external_task_type(&mut self, value: ExternalTaskType)

Sets external_task_type to the provided enum value.

Trait Implementations

impl Clone for TaskConfig

fn clone(&self) -> TaskConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for TaskConfig

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

Formats the value using the given formatter.

impl Default for TaskConfig

fn default() -> Self

Returns the “default value” for a type.

impl Message for TaskConfig

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for TaskConfig

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

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

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

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for TaskConfig