# Packages
nolint.
# Functions
BufferCapacity allows you to specify capacity for the internal server's queue.
No description provided by the author
NewServer returns a new server.
NewSubscription returns a new subscription with the given outCapacity.
# Variables
ErrAlreadySubscribed is returned when a client tries to subscribe twice or more using the same query.
ErrOutOfCapacity is returned by Err when a client is not pulling messages fast enough.
ErrSubscriptionNotFound is returned when a client tries to unsubscribe from not existing subscription.
ErrUnsubscribed is returned by Err when a client unsubscribes.
# Structs
Message glues data and events together.
Server allows clients to subscribe/unsubscribe for messages, publishing messages with or without events, and manages internal state.
A Subscription represents a client subscription for a particular query and consists of three things: 1) channel onto which messages and events are published 2) channel which is closed if a client is too slow or choose to unsubscribe 3) err indicating the reason for (2).
# Interfaces
Query defines an interface for a query to be used for subscribing.
# Type aliases
Option sets a parameter for the server.