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).

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 address of the websocket of the MQTT broker which is advertised to the INX Server (optional).

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.

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