Struct BasePublisher 

pub struct BasePublisher { /* private fields */ }

Creates Publisher instances.

A single BasePublisher can be used to create multiple Publisher clients for different topics. It manages the underlying gRPC connection and authentication.

Example

// Create a client.
let client: BasePublisher = BasePublisher::builder().build().await?;

// Create a publisher for a specific topic.
let publisher = client.publisher("projects/my-project/topics/my-topic").build();

// Publish a message.
let handle = publisher.publish(Message::new().set_data("hello world"));
let message_id = handle.await?;
println!("Message sent with ID: {}", message_id);

Implementations

impl BasePublisher

pub fn builder() -> BasePublisherBuilder

Returns a builder for BasePublisher.

let client: BasePublisher = BasePublisher::builder().build().await?;

pub fn publisher<T>(&self, topic: T) -> PublisherPartialBuilder

where T: Into<String>,

Creates a new Publisher for a given topic.

let client = BasePublisher::builder().build().await?;
let publisher = client.publisher("projects/my-project/topics/my-topic").build();
let message_id = publisher.publish(Message::new().set_data("Hello, World")).await?;

Trait Implementations

impl Clone for BasePublisher

fn clone(&self) -> BasePublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BasePublisher

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

Formats the value using the given formatter.