kafka

type KafkaSinkEvent struct {
	EventMessage        string
	EventReason         string
	EventTimestamp      time.Time
	EventCount          int
	EventInvolvedObject interface{}
	EventSource         interface{}
}

type KafkaSinkPoint struct {
	MetricsName      string
	MetricsValue     interface{}
	MetricsTimestamp time.Time
	MetricsTags      map[string]string
}