Struct Client 

pub struct Client { /* private fields */ }

Creates Publisher instances.

This is the main entry point for the publisher API. A single Client 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 = Client::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(PubsubMessage::new().set_data("hello world"));
let message_id = handle.await?;
println!("Message sent with ID: {}", message_id);

Implementations

impl Client

pub fn builder() -> ClientBuilder

Returns a builder for Client.

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

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

where T: Into<String>,

Creates a new Publisher for a given topic.

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

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Client

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

Formats the value using the given formatter.