Struct PublisherPartialBuilder 

pub struct PublisherPartialBuilder { /* private fields */ }

Creates Publishers with a preconfigured client.

Example

let client: BasePublisher = BasePublisher::builder().build().await?;
let publisher = client.publisher("projects/my-project/topics/topic").build();

Implementations

impl PublisherPartialBuilder

pub fn set_message_count_threshold( self, threshold: u32, ) -> PublisherPartialBuilder

Sets the message count threshold for batching.

The publisher will send a batch of messages when the number of messages in the batch reaches this threshold.

Example

let publisher = client
    .publisher("projects/my-project/topics/my-topic")
    .set_message_count_threshold(100)
    .build();

pub fn set_byte_threshold(self, threshold: u32) -> PublisherPartialBuilder

Sets the byte threshold for batching.

The publisher will send a batch of messages when the total size of the messages in the batch reaches this threshold.

Example

let publisher = client
    .publisher("projects/my-project/topics/my-topic")
    .set_byte_threshold(1024) // 1 KiB
    .build();

pub fn set_delay_threshold(self, threshold: Duration) -> PublisherPartialBuilder

Sets the delay threshold for batching.

The publisher will wait a maximum of this amount of time before sending a batch of messages.

Example

let publisher = client
    .publisher("projects/my-project/topics/my-topic")
    .set_delay_threshold(Duration::from_millis(50))
    .build();

pub fn build(self) -> Publisher

Creates a new Publisher from the builder’s configuration.

Trait Implementations

impl Clone for PublisherPartialBuilder

fn clone(&self) -> PublisherPartialBuilder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PublisherPartialBuilder

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

Formats the value using the given formatter.