Struct hedwig::googlepubsub::SubscriptionConfig [−][src]
pub struct SubscriptionConfig<'s> {
pub name: SubscriptionName<'s>,
pub topic: TopicName<'s>,
pub ack_deadline_seconds: u16,
pub retain_acked_messages: bool,
pub message_retention_duration: Option<Duration>,
pub labels: HashMap<String, String>,
pub enable_message_ordering: bool,
pub expiration_policy: Option<ExpirationPolicy>,
pub filter: String,
pub dead_letter_policy: Option<DeadLetterPolicy>,
pub retry_policy: Option<RetryPolicy>,
}
This is supported on crate feature
google
only.Expand description
Configuration describing a PubSub subscription.
This is a more ergonomic wrapper over pubsub::api::Subscription
Fields
name: SubscriptionName<'s>
See name
topic: TopicName<'s>
See topic
ack_deadline_seconds: u16
retain_acked_messages: bool
message_retention_duration: Option<Duration>
labels: HashMap<String, String>
See labels
enable_message_ordering: bool
expiration_policy: Option<ExpirationPolicy>
filter: String
See filter
dead_letter_policy: Option<DeadLetterPolicy>
retry_policy: Option<RetryPolicy>
See retry_policy
Trait Implementations
Auto Trait Implementations
impl<'s> RefUnwindSafe for SubscriptionConfig<'s>
impl<'s> Send for SubscriptionConfig<'s>
impl<'s> Sync for SubscriptionConfig<'s>
impl<'s> Unpin for SubscriptionConfig<'s>
impl<'s> UnwindSafe for SubscriptionConfig<'s>
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more