messages

type KafkaEventMessage struct {
	TopicType int    `json:"TopicType,omitempty"`
	Key       string `json:"_key,omitempty"`
	Id        string `json:"_id,omitempty"`
	Action    string `json:"action,omitempty"`
}

type MessageHandler func(msg KafkaEventMessage)

type Subscription struct {
	// contains filtered or unexported fields
}

type TelemetryEvent struct {
	Measurement string
	Metric      protocol.Metric
}

type TopologyEvent struct {
	Action   string
	Key      string
	Document interface{}
}