mqtt

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

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

type Options struct {
	URI           string `json:"uri"`
	Username      string `json:"username"`
	Password      string `json:"password"`
	ClientID      string `json:"clientID"`
	TLSCACert     string `json:"tlsCACert"`
	TLSClientCert string `json:"tlsClientCert"`
	TLSClientKey  string `json:"tlsClientKey"`
	TLSSkipVerify bool   `json:"tlsSkipVerify"`
}

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

type TopicMap struct {
	sync.Map
}