Struct TopicBuilder 

pub struct TopicBuilder { /* private fields */ }

Topic builder for fluent topic creation.

Implementations

impl TopicBuilder

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

Creates a new topic builder.

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

Sets message retention duration.

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

Adds a label.

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

Adds multiple labels.

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

Enables message ordering.

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

Sets custom endpoint.

pub fn build(self) -> TopicConfig

Builds the topic configuration.

pub async fn create(self, manager: &TopicManager) -> Result<String>

Creates the topic using a topic manager.