mqtt

type AuthenticatedMsg struct {
	Token   string `json:"token"`
	Records []senml.Record
}

type Authorizer func(topic string, jwt string) error

type Conf struct {
	User       string
	Pass       string
	Host       string
	Port       string
	HealthPort string
}

type MqttSub interface {
	Connect() error
	Subscriber(topic string, qos byte, authorizer Authorizer, handler nats.NatsPubType) error
	Unsubscribe(topic string)
	Disconnect()
}