DecodeFrame decodes the message frame from the decoder.

DecodeMessage decodes the message from the decoder.

New creates a new message structure from the provided SSID, channel and payload.

NewCounters creates a new container.

NewFrame creates a new frame with the specified capacity.

NewID creates a new message identifier for the current time.

NewPrefix creates a new message identifier only containing the prefix.

NewSsid creates a new SSID.

NewSsidForPresence creates a new SSID for presence.

NewSsidForShare creates a new SSID for shared subscriptions.

NewTrie creates a new subscriptions matcher using standard emitter strategy.

NewTrieMQTT creates a new subscriptions matcher using standard MQTT strategy.

RetainedTTL represents a TTL value to use for retained messages (max TTL).

Subscriber types.

Subscriber types.

Subscriber types.

Query represents a constant SSID for a query.

Counter represents a single subscription counter.

Counters represents a subscription counting map.

Message represents a message which has to be forwarded or stored.

Subscription represents a topic subscription.

Trie represents an efficient collection of subscriptions with lookup capability.

Awaiter represents an asynchronously awaiting response channel.

Subscriber is a value associated with a subscription.

Frame represents a message frame which is sent through the wire to the remote server and contains a set of messages.

ID represents a message ID encoded at 128bit and lexigraphically sortable.

Ssid represents a subscription ID which contains a contract and a list of hashes for various parts of the channel.

Subscribers represents a subscriber set which can contain only unique values.

SubscriberType represents a type of subscriber.