AtomicItoa converts an int64 point to a string.

IsSharedFilter returns true if the filter uses the share prefix.

IsValidFilter returns true if the filter is valid.

New returns a new instance of comqtt broker.

NewClients returns an instance of Clients.

NewInboundTopicAliases returns a pointer to InboundTopicAliases.

NewInflights returns a new instance of an Inflight packets map.

NewInlineSubscriptions returns a new instance of InlineSubscriptions.

NewOutboundTopicAliases returns a pointer to OutboundTopicAliases.

NewSharedSubscriptions returns a new instance of Subscriptions.

NewSubscriptions returns a new instance of Subscriptions.

NewTopicAliases returns an instance of TopicAliases.

NewTopicsIndex returns a pointer to a new instance of Index.

Client session inheritance way.

Client session inheritance way.

Client session inheritance way.

the current server version.

DefaultServerCapabilities defines the default features and capabilities provided by the server.

connection is closed.

inline client is not enabled by default.

ErrInvalidConfigType indicates a different Type of config value was expected to what was received.

a listener with the same id already exists.

the prefix indicating a share topic.

the prefix indicating a system info topic.

Capabilities indicates the capabilities and features provided by the server.

Client contains information about a client known by the broker.

ClientConnection contains the connection transport and metadata for the client.

ClientProperties contains the properties which define the client behaviour.

Clients contains a map of the clients known by the broker.

ClientState tracks the state of the client.

Compatibilities provides flags for using compatibility modes.

HookBase provides a set of default methods for each hook.

HookOptions contains values which are inherited from the server on initialisation.

Hooks is a slice of Hook interfaces to be called in sequence.

InboundTopicAliases contains a map of topic aliases received from the client.

Inflight is a map of InflightMessage keyed on packet id.

InlineSubscriptions represents a map of internal subscriptions keyed on client.

Options contains configurable options for the server.

OutboundTopicAliases contains a map of topic aliases sent from the broker to the client.

Server is an MQTT broker server.

SharedSubscriptions contains a map of subscriptions to a shared filter, keyed on share group then client id.

Subscribers contains the shared and non-shared subscribers matching a topic.

Subscriptions is a map of subscriptions keyed on client.

TopicAliases contains inbound and outbound topic alias registrations.

TopicsIndex is a prefix/trie tree containing topic subscribers and retained messages.

Will contains the last will and testament details for a client connection.

Hook provides an interface of handlers for different events which occur during the lifecycle of the broker.

ClientSubscriptions is a map of aggregated subscriptions for a client.

InlineSubFn is the signature for a callback function which will be called when an inline client receives a message on a topic it is subscribed to.

ReadFn is the function signature for the function used for reading and processing new packets.