FromTopic returns the subscription instance for given topic and subscription id.

Get returns the subscriptions that equals the passed topic filter.

GetClientSubscriptions returns the subscriptions of a specific client.

GetFullTopicName returns the full topic name of given shareName and topicFilter.

GetTopicMatched returns the subscriptions that match the passed topic.

NewMockStatsReader creates a new mock instance.

NewMockStore creates a new mock instance.

SplitTopic returns the shareName and topicFilter of the given topic.

TypeNonShared represents non-shared topic.

TypeSYS represents shared topic, which start with '$share/'.

TypeSYS represents system topic, which start with '$'.

IterationOptions.

MockStatsReader is a mock of StatsReader interface.

MockStatsReaderMockRecorder is the mock recorder for MockStatsReader.

MockStore is a mock of Store interface.

MockStoreMockRecorder is the mock recorder for MockStore.

Stats is the statistics information of the store.

StatsReader provides the ability to get statistics information.

Store is the interface used by gmqtt.server to handler the operations of subscriptions.

ClientSubscriptions groups the subscriptions by client id.

IterateFn is the callback function used by iterate() Return false means to stop the iteration.

IterationType specifies the types of subscription that will be iterated.

MatchType specifies what match operation will be performed during the iteration.

SubscribeResult is the result of Subscribe().