invalidator

type Command struct {
	Command string `json:"command"`
	Id      string `json:"id"`
}

type KnownTopics struct {
	DeviceTopic         string
	DeviceTypeTopic     string
	ConceptTopic        string
	CharacteristicTopic string
	FunctionTopic       string
	AspectTopic         string
	HubTopic            string
	DeviceClassTopic    string
	DeviceGroupTopic    string
	ProtocolTopic       string
	LocationTopic       string
}

type SignalInfo struct {
	Signal      signal.Signal
	SignalValue string
}

type SignalMapper = func(message kafka.Message) []SignalInfo