Struct hedwig::googlepubsub::PublisherClient

pub struct PublisherClient<C = DefaultConnector> { /* fields omitted */ }

This is supported on crate feature google only.

A client through which PubSub publishing operations can be performed.

This includes managing topics and writing data to topics. Created using build_publisher

Implementations

impl<C> PublisherClient<C> where
    C: MakeConnection<Uri> + Connect + Clone + Send + Sync + 'static,
    C::Connection: Unpin + Send + 'static,
    C::Future: Send + 'static,
    Box<dyn Error + Send + Sync + 'static>: From<C::Error>, 

pub async fn create_topic(
    &mut self,
    topic: TopicConfig<'_>
) -> Result<(), PubSubError>

Create a new PubSub topic.

See the GCP documentation on topics here

pub async fn delete_topic(
    &mut self,
    topic: TopicName<'_>
) -> Result<(), PubSubError>

Delete an existing PubSub topic.

See the GCP documentation on topics here

pub fn publisher(&self) -> Publisher<C>

Create a a new Publisher instance for publishing messages.

Multiple publishers can be created using the same client, for example to use different validators. They may share some underlying resources for greater efficiency than creating multiple clients.

Trait Implementations

impl<C: Clone> Clone for PublisherClient<C>

fn clone(&self) -> PublisherClient<C>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for PublisherClient<C>

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

Formats the value using the given formatter.