Struct GcpTriggerData 

pub struct GcpTriggerData {

    pub gcp_resource_path: String,
    pub subscription_mode: SubscriptionMode,
    pub topic_id: String,
    pub subscription_id: Option<String>,
    pub base_endpoint: Option<String>,
    pub delivery_type: Option<DeliveryType>,
    pub delivery_config: Option<Box<PushConfig>>,
    pub path: String,
    pub script_path: String,
    pub is_flow: bool,
    pub mode: Option<TriggerMode>,
    pub auto_acknowledge_msg: Option<bool>,
    pub ack_deadline: Option<i32>,
    pub error_handler_path: Option<String>,
    pub error_handler_args: Option<HashMap<String, Value>>,
    pub retry: Option<Box<Retry>>,
}

GcpTriggerData : Data for creating or updating a Google Cloud Pub/Sub trigger.

Fields

gcp_resource_path: String

Path to the GCP resource containing service account credentials for authentication.

subscription_mode: SubscriptionMode

topic_id: String

Google Cloud Pub/Sub topic ID to subscribe to.

subscription_id: Option<String>

Google Cloud Pub/Sub subscription ID.

base_endpoint: Option<String>

Base URL for push delivery endpoint.

delivery_type: Option<DeliveryType>

delivery_config: Option<Box<PushConfig>>

path: String

The unique path identifier for this trigger.

script_path: String

Path to the script or flow to execute when a message is received.

is_flow: bool

True if script_path points to a flow, false if it points to a script.

mode: Option<TriggerMode>

auto_acknowledge_msg: Option<bool>

If true, automatically acknowledge messages after processing.

ack_deadline: Option<i32>

Time in seconds within which the message must be acknowledged. If not provided, defaults to the subscription’s acknowledgment deadline (600 seconds).

error_handler_path: Option<String>

Path to a script or flow to run when the triggered job fails.

error_handler_args: Option<HashMap<String, Value>>

The arguments to pass to the script or flow

retry: Option<Box<Retry>>

Implementations

impl GcpTriggerData

pub fn new( gcp_resource_path: String, subscription_mode: SubscriptionMode, topic_id: String, path: String, script_path: String, is_flow: bool, ) -> GcpTriggerData

Data for creating or updating a Google Cloud Pub/Sub trigger.

Trait Implementations

impl Clone for GcpTriggerData

fn clone(&self) -> GcpTriggerData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GcpTriggerData

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

Formats the value using the given formatter.

impl Default for GcpTriggerData

fn default() -> GcpTriggerData

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for GcpTriggerData

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for GcpTriggerData

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

Tests for self and other values to be equal, and is used by ==.

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

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

impl Serialize for GcpTriggerData

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 GcpTriggerData