Struct GcpPubSubQueueHeartbeatData 

pub struct GcpPubSubQueueHeartbeatData {

    pub status: QueueHeartbeatStatus,
    pub topic_name: String,
    pub subscription_name: Option<String>,
    pub project_id: Option<String>,
    pub topic_full_name: Option<String>,
    pub subscription_full_name: Option<String>,
    pub endpoint: Option<String>,
    pub topic_labels: BTreeMap<String, String>,
    pub subscription_labels: BTreeMap<String, String>,
    pub message_storage_allowed_persistence_regions: Vec<String>,
    pub message_storage_enforce_in_transit: Option<bool>,
    pub kms_key_name: Option<String>,
    pub schema_name: Option<String>,
    pub schema_encoding: Option<String>,
    pub schema_first_revision_id: Option<String>,
    pub schema_last_revision_id: Option<String>,
    pub topic_message_retention_duration: Option<String>,
    pub topic_state: Option<String>,
    pub subscription_ack_deadline_seconds: Option<u32>,
    pub subscription_message_retention_duration: Option<String>,
    pub subscription_retain_acked_messages: Option<bool>,
    pub subscription_enable_message_ordering: Option<bool>,
    pub subscription_filter: Option<String>,
    pub subscription_detached: Option<bool>,
    pub subscription_state: Option<String>,
    pub subscription_push_config_present: Option<bool>,
    pub subscription_push_endpoint: Option<String>,
    pub subscription_push_attributes: BTreeMap<String, String>,
    pub subscription_push_oidc_service_account_email: Option<String>,
    pub subscription_push_oidc_audience: Option<String>,
    pub subscription_push_pubsub_wrapper_write_metadata: Option<bool>,
    pub subscription_push_no_wrapper_write_metadata: Option<bool>,
    pub subscription_dead_letter_topic: Option<String>,
    pub subscription_dead_letter_max_delivery_attempts: Option<u32>,
}

Fields

status: QueueHeartbeatStatus

topic_name: String

subscription_name: Option<String>

project_id: Option<String>

topic_full_name: Option<String>

subscription_full_name: Option<String>

endpoint: Option<String>

topic_labels: BTreeMap<String, String>

subscription_labels: BTreeMap<String, String>

message_storage_allowed_persistence_regions: Vec<String>

message_storage_enforce_in_transit: Option<bool>

kms_key_name: Option<String>

schema_name: Option<String>

schema_encoding: Option<String>

schema_first_revision_id: Option<String>

schema_last_revision_id: Option<String>

topic_message_retention_duration: Option<String>

topic_state: Option<String>

subscription_ack_deadline_seconds: Option<u32>

subscription_message_retention_duration: Option<String>

subscription_retain_acked_messages: Option<bool>

subscription_enable_message_ordering: Option<bool>

subscription_filter: Option<String>

subscription_detached: Option<bool>

subscription_state: Option<String>

subscription_push_config_present: Option<bool>

subscription_push_endpoint: Option<String>

subscription_push_attributes: BTreeMap<String, String>

subscription_push_oidc_service_account_email: Option<String>

subscription_push_oidc_audience: Option<String>

subscription_push_pubsub_wrapper_write_metadata: Option<bool>

subscription_push_no_wrapper_write_metadata: Option<bool>

subscription_dead_letter_topic: Option<String>

subscription_dead_letter_max_delivery_attempts: Option<u32>

Trait Implementations

impl Clone for GcpPubSubQueueHeartbeatData

fn clone(&self) -> GcpPubSubQueueHeartbeatData

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for GcpPubSubQueueHeartbeatData

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

Formats the value using the given formatter.

impl Default for GcpPubSubQueueHeartbeatData

fn default() -> GcpPubSubQueueHeartbeatData

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for GcpPubSubQueueHeartbeatData

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for GcpPubSubQueueHeartbeatData

fn eq(&self, other: &GcpPubSubQueueHeartbeatData) -> 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 GcpPubSubQueueHeartbeatData

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 GcpPubSubQueueHeartbeatData