Struct hedwig::Hedwig

pub struct Hedwig<T, P> { /* fields omitted */ }

Central instance to access all Hedwig related resources

Methods

impl<T, P> Hedwig<T, P> where
    P: Publisher, 

pub fn new(
    schema: &str,
    publisher_name: &str,
    publisher: P,
    message_router: MessageRouter<T>
) -> Result<Hedwig<T, P>, HedwigError>

Creates a new Hedwig instance. Application credentials cannot be auto-discovered in Google Cloud environment unlike the Python library.

Arguments

• schema: The JSON schema content. It's up to the caller to read the schema from a file.
• publisher name: Name of the publisher service. This will be part of the metadata in the message.
• publisher - An implementation of Publisher
• message_router - A function that can route messages to topics

pub fn message<D>(
    &self,
    data_type: T,
    data_schema_version: Version,
    data: D
) -> Result<Message<D, T>, MessageError> where
    D: Serialize,
    T: Copy + Into<&'static str>, 

Creates a new message with given data type, schema version and data object.

Arguments

• data_type - An Enum instance with static str representation
• data_schema_version - Version of the data object
• data - The message data - must be serializable

pub fn publish<D>(&self, message: Message<D, T>) -> Result<String, PublishError> where
    D: Serialize, 

Publish a message using the configured publisher. Returns the publish id if successful. The publish id depends on your publisher.

Arguments

• message - the message to publish