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

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

NewConsumer returns an initialised Consumer.

NewPublisher returns an initialised Publisher.

Success should be returned when the message was successfully processed.

Consumer uses Redis Streams to publish and subscribe.

ConsumerOptions contains options to configure the Consumer.

HandlerError wraps any errors returned from message handlers.

HandlerPanic is returned if a message handler panics.

Message represents a message published to or received from a Redis stream.

NetworkError is returned if a network error occurs when communicating with Redis.

Publisher is capable of publishing messages to Redis Streams.

PublisherOptions contains options to configure the Publisher.

RedisError is returned if the Redis client returns an error that is not a network error.

Result defines the result of a handler.

Handler processes messages.

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