Struct SubscriptionCreateConfig 

pub struct SubscriptionCreateConfig {

    pub project_id: String,
    pub subscription_name: String,
    pub topic_name: String,
    pub ack_deadline_seconds: i64,
    pub message_retention_duration: Option<i64>,
    pub retain_acked_messages: bool,
    pub enable_message_ordering: bool,
    pub expiration_policy: Option<ExpirationPolicy>,
    pub dead_letter_policy: Option<DeadLetterPolicy>,
    pub retry_policy: Option<RetryPolicy>,
    pub labels: HashMap<String, String>,
    pub filter: Option<String>,
    pub endpoint: Option<String>,
}

Subscription configuration for creation/updates.

Fields

project_id: String

Project ID.

subscription_name: String

Subscription name.

topic_name: String

Topic name to subscribe to.

ack_deadline_seconds: i64

Acknowledgment deadline in seconds.

message_retention_duration: Option<i64>

Message retention duration in seconds.

retain_acked_messages: bool

Retain acknowledged messages.

enable_message_ordering: bool

Enable message ordering.

expiration_policy: Option<ExpirationPolicy>

Expiration policy.

dead_letter_policy: Option<DeadLetterPolicy>

Dead letter policy.

retry_policy: Option<RetryPolicy>

Retry policy.

labels: HashMap<String, String>

Labels.

filter: Option<String>

Filter expression.

endpoint: Option<String>

Custom endpoint.

Implementations

impl SubscriptionCreateConfig

pub fn new( project_id: impl Into<String>, subscription_name: impl Into<String>, topic_name: impl Into<String>, ) -> Self

Creates a new subscription configuration.

pub fn with_ack_deadline(self, seconds: i64) -> Self

Sets the acknowledgment deadline.

pub fn with_message_retention(self, seconds: i64) -> Self

Sets message retention duration.

pub fn with_retain_acked_messages(self, retain: bool) -> Self

Sets whether to retain acknowledged messages.

pub fn with_message_ordering(self, enable: bool) -> Self

Enables message ordering.

pub fn with_expiration_policy(self, policy: ExpirationPolicy) -> Self

Sets the expiration policy.

pub fn with_dead_letter_policy(self, policy: DeadLetterPolicy) -> Self

Sets the dead letter policy.

pub fn with_retry_policy(self, policy: RetryPolicy) -> Self

Sets the retry policy.

pub fn with_label( self, key: impl Into<String>, value: impl Into<String>, ) -> Self

Adds a label.

pub fn with_labels(self, labels: HashMap<String, String>) -> Self

Adds multiple labels.

pub fn with_filter(self, filter: impl Into<String>) -> Self

Sets a filter expression.

pub fn with_endpoint(self, endpoint: impl Into<String>) -> Self

Sets a custom endpoint.

Trait Implementations

impl Clone for SubscriptionCreateConfig

fn clone(&self) -> SubscriptionCreateConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionCreateConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for SubscriptionCreateConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for SubscriptionCreateConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.