GenerateQueueName takes in a Subscription, extracts the headers and topics and returns a consistent but unique queue name.

IsErrorRetryable returns true if the error is retryable.

IsHTTPStatusRetryable returns true if the status code is retryable.

NewSubscription will create a subscription to the event server and will continously read events (as they arrive) and send them back to the return channel.

Publish will publish an event to the event api server.

WithAsync will set the async flag on publishing when using a SubscriptionChannel and is ignored when using the Publish method of the package.

WithDeadline will set a deadline for publishing.

WithDebugOption will turn on debugging.

WithHeaders will provide an ability to set specific headers on the outgoing HTTP request.

WithLogger will provide a logger to use.

WithTimestamp will set the timestamp on the event payload.

IngestQueueName is the name of the eventapi ingest queue.

ErrDeadlineExceeded is an error that's raised when a deadline occurs.

EventDebug allows debug printing without requiring a logger to make it easy to turn on for debugging on the fly with an env variable.

MaxErrorCount is the number of errors trying to connect to the event-api server before giving up.

MinCompressionSize is the minimum size for compression on Publish.

PublishConfig is used by Options.

PublishEvent is the container for a model event.

Subscription is the information for creating a subscription channel to receive events from the event server.

SubscriptionChannel is a channel for receiving events.

SubscriptionEvent is received from the event server.

SubscriptionFilter are subscription related filters.

Option will allow publish to be customized.