mqttClient

type Client interface {
	Name() string
	Run()
	Shutdown()
	ReplaceTemplate(template string) string
	AddRoute(subscribeTopic string, messageHandler MessageHandler)
}

type ClientPool struct {
	// contains filtered or unexported fields
}

type ClientStruct struct {
	// contains filtered or unexported fields
}

type ClientV3 struct {
	ClientStruct
	// contains filtered or unexported fields
}

type ClientV5 struct {
	ClientStruct
	// contains filtered or unexported fields
}

type Config interface {
	Name() string
	Broker() *url.URL
	User() string
	Password() string
	ClientId() string
	Qos() byte
	KeepAlive() time.Duration
	ConnectRetryDelay() time.Duration
	ConnectTimeout() time.Duration
	AvailabilityTopic() string
	TopicPrefix() string
	LogDebug() bool
	LogMessages() bool
}

type Message struct {
	// contains filtered or unexported fields
}

type MessageHandler func(Message)

type Statistics interface {
	IncrementOne(module, name, field string)
}