NewBroker creates a new broker.

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

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

WithClientReadBufferSize specifies the size of the client read buffer.

WithClientWriteBufferSize specifies the size of the client write buffer.

WithMaximumClientWritesPending specifies the maximum number of pending message writes for a client.

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

WithProtectedTopics sets the MQTT topics which only can be subscribed to with valid authorization.

WithPublicTopics sets the MQTT topics which can be subscribed to without authorization.

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.

BrokerHook is the glue code between the mochi-mqtt server and inx-mqtt.

Options are options around the broker.

Option is a function which sets an option on a Options instance.