nolint.

BufferCapacity allows you to specify capacity for the internal server's queue.

NewServer returns a new server.

NewTagMap constructs a new immutable tag set from a map.

ErrAlreadySubscribed is returned when a client tries to subscribe twice or more using the same query.

ErrSubscriptionNotFound is returned when a client tries to unsubscribe from not existing subscription.

Server allows clients to subscribe/unsubscribe for messages, publishing messages with or without tags, and manages internal state.

Query defines an interface for a query to be used for subscribing.

TagMap is used to associate tags to a message.

Option sets a parameter for the server.