Struct hedwig::GooglePublisher

pub struct GooglePublisher { /* fields omitted */ }

A publisher that uses Google PubSub. To use this class, add feature google.

Examples

let publisher = GooglePublisher::new(String::from("/home/.google-key.json"), "myproject".into())?;

Methods

impl GooglePublisher

pub fn new<P>(
    google_application_credentials: P,
    google_cloud_project: String
) -> Result<GooglePublisher, HedwigError> where
    P: AsRef<Path>, 

Create a new instance of GooglePublisher For now, this requires explicitly passing in the path to your credentials file, as well as the name of the project where pubsub infra lives.

Arguments

• google_application_credentials - Path to the google credentials file.
• google_cloud_project - The Google Cloud project where your pubsub resources lie - this /may be/ different from the credentials.

Trait Implementations

impl Publisher for GooglePublisher

type MessageIds = Vec<String>

The list of identifiers for successfully published messages.

fn publish(
    &self,
    messages: Vec<(&'static str, ValidatedMessage)>
) -> Result<Self::MessageIds, PublishError>

Publishes a message on Google Pubsub and returns a pubsub id (usually an integer).