Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type PrometheusService ¶
type PrometheusService struct {
// contains filtered or unexported fields
}
PrometheusService collects Kafka metrics from a Prometheus server
func NewPrometheusService ¶
func NewPrometheusService(promClient *client.PrometheusClient) *PrometheusService
NewPrometheusService creates a new Prometheus metrics service
func (*PrometheusService) CollectMetrics ¶
func (s *PrometheusService) CollectMetrics(ctx context.Context, queryRange time.Duration) (*types.ProcessedClusterMetrics, error)
CollectMetrics queries Prometheus for all Kafka metrics over the specified range
Source Files
Click to show internal directories.
Click to hide internal directories.