AddGlobalPrefixToTopic , adds prefix to topic .

DetachGlobalPrefixFromTopic detaches domain from topic.

NewBinaryMessage transport message is meant to carry original message using either encryption , signing or.

NewMqttTransport constructor.

NewSyncClient creates sync client using existing mqtt connection.

NewSyncClientV2 creates new sync client using existing mqtt connection and configures transactionPool size and inboundBufferSize.

ParseTime is a helper function to parse a timestamp from a string from various variations of RFC3339.

Constants defining storage strategies.

Constants defining storage strategies.

Constants defining storage strategies.

Storage is used to define optional message storage strategy.

SyncClient allows sync interaction over async channel.

StorageStrategy defines message storage strategy.