Discard should be returned when the event was not successfully processed but should not be retried.

Fail should be returned when the event was not successfully processed and should be retried.

NewClient returns a new Firehose client.

Success should be returned when the event was successfully processed.

Client implements the Publish and Subscribe interfaces.

ClientOptions contains fields to configure the Firehose client.

MockClient can be used by unit tests.

Handler processes messages received on a channel that has been subscribed to.

Publisher is the interface that wraps the publish method.

Subscriber is the interface that wraps the subscribe method.

Decoder is a function that decodes an event into v.

HandlerFunc is an adapter that allows ordinary functions to be used as event handlers.

Result is an alias for queuer.Result.