Versions in this module Expand all Collapse all v1 v1.0.0 Sep 7, 2022 Changes in this version + var ErrClientNotExists = errors.New("client not exists") + func FromTopic(topic packets.Topic, id uint32) *gmqtt.Subscription + func GetClientSubscriptions(store Store, clientID string, t IterationType) []*gmqtt.Subscription + func GetFullTopicName(shareName, topicFilter string) string + func SplitTopic(topic string) (shareName, topicFilter string) + type ClientSubscriptions map[string][]*gmqtt.Subscription + func Get(store Store, topicFilter string, t IterationType) ClientSubscriptions + func GetTopicMatched(store Store, topicFilter string, t IterationType) ClientSubscriptions + type IterateFn func(clientID string, sub *gmqtt.Subscription) bool + type IterationOptions struct + ClientID string + MatchType MatchType + TopicName string + Type IterationType + type IterationType byte + const TypeAll + const TypeNonShared + const TypeSYS + const TypeShared + type MatchType byte + const MatchFilter + const MatchName + type MockStatsReader struct + func NewMockStatsReader(ctrl *gomock.Controller) *MockStatsReader + func (m *MockStatsReader) EXPECT() *MockStatsReaderMockRecorder + func (m *MockStatsReader) GetClientStats(clientID string) (Stats, error) + func (m *MockStatsReader) GetStats() Stats + type MockStatsReaderMockRecorder struct + func (mr *MockStatsReaderMockRecorder) GetClientStats(clientID interface{}) *gomock.Call + func (mr *MockStatsReaderMockRecorder) GetStats() *gomock.Call + type MockStore struct + func NewMockStore(ctrl *gomock.Controller) *MockStore + func (m *MockStore) Close() error + func (m *MockStore) EXPECT() *MockStoreMockRecorder + func (m *MockStore) GetClientStats(clientID string) (Stats, error) + func (m *MockStore) GetStats() Stats + func (m *MockStore) Init(clientIDs []string) error + func (m *MockStore) Iterate(fn IterateFn, options IterationOptions) + func (m *MockStore) Subscribe(clientID string, subscriptions ...*gmqtt.Subscription) (SubscribeResult, error) + func (m *MockStore) Unsubscribe(clientID string, topics ...string) error + func (m *MockStore) UnsubscribeAll(clientID string) error + type MockStoreMockRecorder struct + func (mr *MockStoreMockRecorder) Close() *gomock.Call + func (mr *MockStoreMockRecorder) GetClientStats(clientID interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) GetStats() *gomock.Call + func (mr *MockStoreMockRecorder) Init(clientIDs interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) Iterate(fn, options interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) Subscribe(clientID interface{}, subscriptions ...interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) Unsubscribe(clientID interface{}, topics ...interface{}) *gomock.Call + func (mr *MockStoreMockRecorder) UnsubscribeAll(clientID interface{}) *gomock.Call + type Stats struct + SubscriptionsCurrent uint64 + SubscriptionsTotal uint64 + type StatsReader interface + GetClientStats func(clientID string) (Stats, error) + GetStats func() Stats + type Store interface + Close func() error + Init func(clientIDs []string) error + Iterate func(fn IterateFn, options IterationOptions) + Subscribe func(clientID string, subscriptions ...*gmqtt.Subscription) (rs SubscribeResult, err error) + Unsubscribe func(clientID string, topics ...string) error + UnsubscribeAll func(clientID string) error + type SubscribeResult = []struct