Struct MessageStoragePolicy 

#[non_exhaustive]
pub struct MessageStoragePolicy {
    pub allowed_persistence_regions: Vec<String>,
    pub enforce_in_transit: bool,
    /* private fields */
}

A policy constraining the storage of messages published to the topic.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

allowed_persistence_regions: Vec<String>

Optional. A list of IDs of Google Cloud regions where messages that are published to the topic may be persisted in storage. Messages published by publishers running in non-allowed Google Cloud regions (or running outside of Google Cloud altogether) are routed for storage in one of the allowed regions. An empty list means that no regions are allowed, and is not a valid configuration.

enforce_in_transit: bool

Optional. If true, allowed_persistence_regions is also used to enforce in-transit guarantees for messages. That is, Pub/Sub will fail Publish operations on this topic and subscribe operations on any subscription attached to this topic in any region that is not in allowed_persistence_regions.

Implementations

impl MessageStoragePolicy

pub fn new() -> Self

pub fn set_allowed_persistence_regions<T, V>(self, v: T) -> Self

where T: IntoIterator<Item = V>, V: Into<String>,

Sets the value of allowed_persistence_regions.

Example

let x = MessageStoragePolicy::new().set_allowed_persistence_regions(["a", "b", "c"]);

pub fn set_enforce_in_transit<T: Into<bool>>(self, v: T) -> Self

Sets the value of enforce_in_transit.

Example

let x = MessageStoragePolicy::new().set_enforce_in_transit(true);

Trait Implementations

impl Clone for MessageStoragePolicy

fn clone(&self) -> MessageStoragePolicy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MessageStoragePolicy

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

Formats the value using the given formatter.

impl Default for MessageStoragePolicy

fn default() -> MessageStoragePolicy

Returns the “default value” for a type.

impl Message for MessageStoragePolicy

fn typename() -> &'static str

The typename of this message.

impl PartialEq for MessageStoragePolicy

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