New returns a new ShrinkingMap.

NewBroker creates a new broker.

WithBufferBlockSize sets the size per client buffer R/W block in bytes.

WithBufferSize sets the size of the client buffers in bytes.

WithMaxTopicSubscriptionsPerClient sets the maximum number of topic subscriptions per client before the client gets dropped (DOS protection).

WithShrinkingThresholdCount defines the count of deletions that triggers shrinking of the map.

WithShrinkingThresholdRatio defines the ratio between the amount of deleted keys and the current map's size before shrinking is triggered.

WithTCPAuthEnabled sets whether to enable auth for TCP connections.

WithTCPAuthPasswordSalt sets the auth salt used for hashing the passwords of the users.

WithTCPAuthUsers sets the list of allowed users with their password+salt as a scrypt hash.

WithTCPBindAddress sets the TCP bind address on which the MQTT broker listens on.

WithTCPEnabled sets whether to enable the TCP connection of the MQTT broker.

WithTCPTLSCertificatePath sets the path to the certificate file (x509 PEM) for TCP connections with TLS.

WithTCPTLSEnabled sets whether to enable TLS for TCP connections.

WithTCPTLSPrivateKeyPath sets the path to the private key file (x509 PEM) for TCP connections with TLS.

WithTopicCleanupThresholdCount sets the number of deleted topics that trigger a garbage collection of the SubscriptionManager.

WithTopicCleanupThresholdRatio the ratio of subscribed topics to deleted topics that trigger a garbage collection of the SubscriptionManager.

WithWebsocketBindAddress sets the websocket bind address on which the MQTT broker listens on.

WithWebsocketEnabled sets whether to enable the websocket connection of the MQTT broker.

AuthAllowBasicAuth allows users that authenticate with basic auth, but without write permission.

AuthAllowEveryone allows everyone, but without write permission.

Broker is a simple mqtt publisher abstraction.

BrokerOptions are options around the broker.

Options define options for a ShrinkingMap.

ShrinkingMap provides a non concurrent-safe map that shrinks if certain conditions are met (AND condition).

SubscriptionManager keeps track of subscribed topics of clients of the mqtt broker by subscribing to broker events.

BrokerOption is a function which sets an option on a BrokerOptions instance.

Option is a function setting an Options option.