# Functions
Create a new Handler with the given processors, successMessenger, and handler options.
NewPubSubMessenger creates a new instance of the PubSubMessenger.
WithFailureMessenger returns an option to set the Messenger for unsuccessfully processed pmap event when creating an EventHandler.
WithStorageClient returns an option to set the GCS storage client when creating an EventHandler.
# Constants
AttrKeyProcessErr is the attribute key for process error.
These are metadatas for GCS objects that were uploaded.
No description provided by the author
No description provided by the author
These are metadatas for GCS objects that were uploaded.
These are metadatas for GCS objects that were uploaded.
These are metadatas for GCS objects that were uploaded.
These are metadatas for GCS objects that were uploaded.
These are metadatas for GCS objects that were uploaded.
These are metadatas for GCS objects that were uploaded.
These are metadatas for GCS objects that were uploaded.
# Structs
EventHandler retrieves GCS objects upon receiving GCS notifications via Pub/Sub, calls a list of processors to process the objects, and lastly passes the objects downstream.
HandlerConfig defines the set over environment variables required for running this application.
HandlerOpts available when creating an EventHandler such as GCS storage client and Messenger for failure events.
MappingConfig defines the environment variables required for running mapping service.
NoopMessenger is a no-op implementation of Messenger interface.
PubSubMessage is the payload of a [Pub/Sub message].
PubSubMessenger implements the Messenger interface for Google Cloud PubSub.
# Interfaces
An interface for sending pmap event downstream.
A generic interface for processing proto messages.
Wrap the proto message interface.
StoppableProcessor is the interface to processors that are stoppable.
# Type aliases
Define your option to change HandlerOpts.