Module hedwig::googlepubsub

Adapters for using GCP’s PubSub as a message service for hedwig

Re-exports

• pub use ya_gcp as gcp;

Modules

• retry_policy
  A collection of traits and types used to retry asynchronous operations.

Structs

• AcknowledgeError
  An error encountered when issuing acks, nacks, or modifications from an AcknowledgeToken
• AcknowledgeToken
  A token with an associated message produced by the StreamSubscription stream, used to control that message’s re-delivery within the message queue.
• BuildError
  An error encountered when building PubSub clients
• ClientBuilder
  A builder used to create ConsumerClient and PublisherClient instances
• ClientBuilderConfig
  Configuration for creating a ClientBuilder
• ConsumerClient
  A client through which PubSub consuming operations can be performed.
• PubSubConfig
  Configuration for connecting to pubsub
• PubSubError
  A gRPC status describing the result of an RPC call.
• PubSubRetryCheck
  The default RetryPredicate used for errors from PubSub operations
• PubSubStream
  A stream of messages from a subscription in PubSub.
• PublishSink
  A sink for publishing messages to pubsub topics.
• Publisher
  A publisher for sending messages to PubSub topics
• PublisherClient
  A client through which PubSub publishing operations can be performed.
• StatusCodeSet
  A set of tonic::Code which can be efficiently checked for the presence or absence of certain code values.
• StreamSubscriptionConfig
  Configuration for a streaming subscription request
• SubscriptionConfig
  Configuration describing a PubSub subscription.
• SubscriptionName
  A PubSub subscription name.
• TopicConfig
  Configuration describing a PubSub topic.
• TopicName
  A PubSub topic name.
• Uri
  The URI component of a request.

Enums

• AuthFlow
  A marker to choose the mechanism by which authentication credentials should be loaded
• CreateBuilderError
  The possible errors encountered when creating a ClientBuilder
• ModifyAcknowledgeError
  An error encountered when issuing deadline modifications with AcknowledgeToken::modify_deadline
• PubSubStreamError
  Errors encountered while streaming messages from PubSub
• PublishError
  Errors which can occur while publishing a message
• ServiceAccountAuth
  Configuration for loading service account credentials from file
• SinkError
  An error that may occur when submitting messages to the PublishTopicSink

Type Aliases

• PubSubMessage
  A message received from PubSub.