NewGCPClient returns a new PubSubClient able to interact with GCP IoT Core apis Currently only support authorizing the client using Application Default Credentials.

NewKafkaPubSubClient creates a new PubSubClient backed by Kafka.

NewMockMQTTClient creates a new mock instance.

NewMockMQTTMessage creates a new mock instance.

NewMockMQTTToken creates a new mock instance.

NewMockPubSubClient creates a new mock instance.

NewMQTTPubSubClient creates and connect a new PubSubClient over MQTT.

List of MQTT availabe QoS.

List of MQTT availabe QoS.

List of MQTT availabe QoS.

ErrAlreadyConnected is returned when trying to connect an already connected client.

ErrInvalidTopic is returned when a topic contains invalid characters.

ErrMQTTTimeout is returned when the response from the mqtt broker timeout.

ErrNotConnected is returned when trying to disconnect a not connected client.

MockMQTTClient is a mock of MQTTClient interface.

MockMQTTClientMockRecorder is the mock recorder for MockMQTTClient.

MockMQTTMessage is a mock of MQTTMessage interface.

MockMQTTMessageMockRecorder is the mock recorder for MockMQTTMessage.

MockMQTTToken is a mock of MQTTToken interface.

MockMQTTTokenMockRecorder is the mock recorder for MockMQTTToken.

MockPubSubClient is a mock of PubSubClient interface.

MockPubSubClientMockRecorder is the mock recorder for MockPubSubClient.

MQTTClient defines a minimal mqtt.Client needed to support E4 protocol.

MQTTMessage wrap around a mqtt.Message.

MQTTToken wrap around a mqtt.Token.

PubSubClient defines a publish / subscribe client interface for the E4 service.