ConnectorFactory implements mqhub.ConnectorFactory.

Encode encodes original message into bytes.

EndpointTopic creates a topic for endpoints.

MakeHandlerRef builds a HandlerRef.

NewConnector creates a connector.

NewMessage wraps mqtt message.

NewOptions creates options.

NewTopicFilter parses a topic filter in string.

NewTopicHandlerMap creates a new TopicHandlerMap.

ParseTopic parse topic including the prefix.

ParseTopicRel parse topic without prefix (start with component ID).

SubCompTopic creates a topic for sub-components.

TokenizeTopic split topic into tokens.

OptClientID is the property name in URL query.

Protocol is the name of protocol for connector.

Connector connects to MQTT.

DataEmitter is a consumer which publish the data to hub.

DataSink is a consumer receives messages from hub.

Descriptor represents advertisements and implements mqhub.Descriptor.

EndpointRef implements mqhub.EndpointRef.

Future implements mqhub.Future.

HandlerRef wraps over a handler.

Message implements Message.

Options defines configuration for connection.

Publication implements mqhub.Publication.

TopicFilter defines a parsed topic filter.

TopicHandlerMap maps topic filter to handlers.