mqtt

type Client interface {
	GetTopic(string) (*Topic, bool)
	IsConnected() bool
	Subscribe(string) *Topic
	Unsubscribe(string)
	Dispose()
}

type Message struct {
	Timestamp time.Time
	Value     []byte
}

type Options struct {
	URI      string `json:"uri"`
	Username string `json:"username"`
	Password string `json:"password"`
}

type Topic struct {
	Path     string `json:"topic"`
	Interval time.Duration
	Messages []Message
	// contains filtered or unexported fields
}

type TopicMap struct {
	sync.Map
}