Struct hedwig::googlepubsub::ConsumerClient

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

This is supported on crate feature google only.

A client through which PubSub consuming operations can be performed.

This includes managing subscriptions and reading data from subscriptions. Created using build_consumer

Implementations

impl<C> ConsumerClient<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_subscription(
    &mut self,
    config: SubscriptionConfig<'_>
) -> Result<(), PubSubError>

Create a new PubSub subscription

See the GCP documentation on subscriptions here

pub async fn delete_subscription(
    &mut self,
    subscription: SubscriptionName<'_>
) -> Result<(), PubSubError>

Delete an existing PubSub subscription.

See the GCP documentation on subscriptions here

pub fn stream_subscription(
    &mut self,
    subscription: SubscriptionName<'_>,
    stream_config: StreamSubscriptionConfig
) -> PubSubStream<C>

Connect to PubSub and start streaming messages from the given subscription

pub async fn seek(
    &mut self,
    subscription: SubscriptionName<'_>,
    timestamp: Timestamp
) -> Result<(), PubSubError>

Seeks messages from the given timestamp. It marks as acknowledged all the messages prior to the timestamp, and as not acknowledged the messages after the timestamp.

Trait Implementations

impl<C: Clone> Clone for ConsumerClient<C>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Debug> Debug for ConsumerClient<C>

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

Formats the value using the given formatter.