Struct TopicConfig 

pub struct TopicConfig {
    pub project_id: String,
    pub topic_name: String,
    pub message_retention_duration: Option<i64>,
    pub labels: HashMap<String, String>,
    pub enable_message_ordering: bool,
    pub endpoint: Option<String>,
}

Topic configuration.

Fields

project_id: String

Project ID.

topic_name: String

Topic name.

message_retention_duration: Option<i64>

Message retention duration in seconds.

labels: HashMap<String, String>

Labels for the topic.

enable_message_ordering: bool

Enable message ordering.

endpoint: Option<String>

Custom endpoint (for testing).

Implementations

impl TopicConfig

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

Creates a new topic configuration.

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

Sets the message retention duration.

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

Adds a label to the topic.

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

Adds multiple labels to the topic.

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

Enables message ordering.

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

Sets a custom endpoint.

Trait Implementations

impl Clone for TopicConfig

fn clone(&self) -> TopicConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TopicConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for TopicConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for TopicConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.