Versions in this module Expand all Collapse all v0 v0.0.1 Feb 17, 2022 Changes in this version + const MQTT_QOS_0 + const MQTT_QOS_1 + const MQTT_QOS_2 + func NewMqttClient(config MqttConfig) (mqtt.Client, error) + func SetMqttLogger(logger *log.Logger) + type Archiver struct + FilterRegex string + Logger *log.Logger + MqttConfig MqttConfig + S3Config S3Config + SubscribePattern string + WorkingDir string + func (archiver *Archiver) StartArchive() error + func (archiver *Archiver) StopArchive() + type EventLogEntry struct + Payload []byte + Timestamp time.Time + Topic string + Version int + type MqttConfig struct + BrokerURL string + ClientID string + GracePeriod time.Duration + Password string + Timeout time.Duration + Username string + type S3Config struct + AccessKey string + BucketName string + Endpoint string + SecretKey string + UseSSL bool
Go to main page