Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 Changes in this version + type TrieDB struct + func NewStore() *TrieDB + func (db *TrieDB) Close() error + func (db *TrieDB) GetClientStats(clientID string) (subscription.Stats, error) + func (db *TrieDB) GetClientStatsLocked(clientID string) (subscription.Stats, error) + func (db *TrieDB) GetStats() subscription.Stats + func (db *TrieDB) GetStatusLocked() subscription.Stats + func (db *TrieDB) Init(clientIDs []string) error + func (db *TrieDB) Iterate(fn subscription.IterateFn, options subscription.IterationOptions) + func (db *TrieDB) IterateLocked(fn subscription.IterateFn, options subscription.IterationOptions) + func (db *TrieDB) Subscribe(clientID string, subscriptions ...*gmqtt.Subscription) (subscription.SubscribeResult, error) + func (db *TrieDB) SubscribeLocked(clientID string, subscriptions ...*gmqtt.Subscription) subscription.SubscribeResult + func (db *TrieDB) Unsubscribe(clientID string, topics ...string) error + func (db *TrieDB) UnsubscribeAll(clientID string) error + func (db *TrieDB) UnsubscribeAllLocked(clientID string) + func (db *TrieDB) UnsubscribeLocked(clientID string, topics ...string)
Go to main page