converter

type Config interface {
	Name() string
	Implementation() string
	InfluxClients() []string
	LogHandleOnce() bool
	LogDebug() bool
}

type EnumTelemetryValue struct {
	Category    string `json:"Cat"`
	Description string `json:"Desc"`
	EnumIdx     int    `json:"Idx"`
	Value       string `json:"Val"`
}

type HandleFunc func(c Config, topicMatcher TopicMatcher, input Input, outputFunc OutputFunc)

type Input interface {
	Topic() string
	Payload() []byte
}

type Output interface {
	Measurement() string
	Tags() map[string]string
	Fields() map[string]interface{}
	Time() time.Time
}

type OutputFunc func(output Output)

type TopicMatcher interface {
	MatchDevice(messageTopic string) (device string, err error)
	GetSubscribeTopic() string
}

type TopicMatcherConfig interface {
	Topic() string
	Device() string
	DeviceIsDynamic() bool
}