Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // ErrNotAccepted new connection does not meet requirements ErrNotAccepted = errors.New("Connection not accepted") // ErrDupNotAllowed case when new client with existing ID connected ErrDupNotAllowed = errors.New("duplicate not allowed") )
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { // Topics manager for all the client subscriptions TopicsMgr topicsTypes.Provider Persist persistenceTypes.Provider Systree systree.Provider // OnDuplicate If requested we notify if there is attempt to dup session OnDuplicate func(string, bool) NodeName string // The number of seconds to wait for the CONNACK message before disconnecting. // If not set then default to 2 seconds. ConnectTimeout int // The number of seconds to keep the connection live if there's no data. // If not set then defaults to 5 minutes. KeepAlive int // AllowDuplicates Either allow or deny replacing of existing session if there new client with same clientID AllowDuplicates bool OfflineQoS0 bool }
Config manager configuration
Click to show internal directories.
Click to hide internal directories.