Struct PubSubClient

pub struct PubSubClient { /* private fields */ }

Implementations

impl PubSubClient

pub async fn publish<M, E>( &self, topic_id: &str, envelopes: Vec<E>, ordering_key: Option<&str>, timeout: Option<Duration>, ) -> Result<Vec<String>, Error>

where M: Serialize, E: Into<PublishedMessageEnvelope<M>> + Debug,

pub async fn publish_raw( &self, topic_id: &str, messages: Vec<RawPublishedMessage<'_>>, timeout: Option<Duration>, ) -> Result<Vec<String>, Error>

impl PubSubClient

pub async fn pull<M>( &self, subscription_id: &str, max_messages: u32, timeout: Option<Duration>, ) -> Result<Vec<PulledMessage<M>>, Error>

where M: DeserializeOwned + Debug,

pub async fn pull_with_transform<M, T>( &self, subscription_id: &str, max_messages: u32, timeout: Option<Duration>, transform: T, ) -> Result<Vec<PulledMessage<M>>, Error>

where M: DeserializeOwned + Debug, T: Fn(&RawPulledMessageEnvelope, Value) -> Result<Value, Box<dyn StdError + Send + Sync + 'static>>,

pub async fn pull_raw( &self, subscription_id: &str, max_messages: u32, timeout: Option<Duration>, ) -> Result<Vec<RawPulledMessageEnvelope>, Error>

pub async fn acknowledge( &self, subscription_id: &str, ack_ids: Vec<&str>, timeout: Option<Duration>, ) -> Result<(), Error>

According to how Google Cloud Pub/Sub works, passing at least one invalid ACK ID fails the whole request via a 400 Bad Request response.

impl PubSubClient

pub fn new<T>(key_path: T, refresh_buffer: Duration) -> Result<Self, Error>

where T: AsRef<str>,

Trait Implementations

impl Debug for PubSubClient

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

Formats the value using the given formatter.