IsValidConsumerName checks if the consumer name is valid.

IsValidStreamName checks if the stream name is valid.

IsValidSubject checks if the subject is valid, either allowing or disallowing wildcards.

NewManager creates a new event manager.

DiscardPolicyNew discards new messages when the stream reaches its maximum size.

DiscardPolicyOld discards old messages when the stream reaches its maximum size.

StorageTypeFile uses file storage for the stream.

StorageTypeMemory uses memory storage for the stream.

ErrPublishTimeout is used when publishing of an event does not meet the deadline.

ErrUnboundSubject is used when a subject is not bound to a stream.

ErrWrongSequence is used when the expected sequence number does not match the actual sequence number.

Module for FX that enables events.

Consumer describes a consumer of events from a stream.

ConsumerConfig is the configuration for creating a consumer.

Event represents a single event consumed from a stream.

EventConsumeConfig is the configuration for consuming events from a stream.

Events is used to receive events from a stream.

Headers contains information about an event.

Manager is used to manage everything related to events, streams, consumers, event publishing, and event consuming.

PublishConfig is the configuration for publishing an event.

PublishedEvent contains information about a published event.

Stream contains information about a stream.

StreamConfig is the configuration for creating or updating a stream.

StreamPointer is a pointer to a position in a stream.

StreamSource defines a source for events in a stream.

DiscardPolicy controls the policy for discarding messages when the stream reaches its maximum size.

StorageType controls the type of storage to use for a stream.

ZapConsumerConfig is a wrapper around jetstream.ConsumerConfig that makes it loggable in a structured way.