metrics

type BaseMetric struct {
	Name      string
	Key       string
	Timestamp time.Time
	Meta      map[string]any
}

type KafkaGauge struct {
	BaseMetric
	metrics.Gauge
}

type KafkaMeter struct {
	BaseMetric
	metrics.Meter
}

type KafkaSource struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

type Sink interface {
	GetMetricsChan() chan<- []any
	Close() error
}

type SinkFunc func() (Sink, error)