Documentation
¶
Index ¶
Constants ¶
View Source
const (
//MetricSuffix the suffix of lag metric
MetricSuffix = "-lag"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaMetricsClient ¶
type KafkaMetricsClient interface {
GetCustomMetric(request MetricRequest, metricSelector labels.Selector) (float64, error)
}
KafkaMetricsClient provides methods for accessing Kafka clusters APIs
func NewClient ¶
func NewClient(client client.Client, corev1Itf corev1.CoreV1Interface) KafkaMetricsClient
NewClient creates a client for calling Application
type KafkaTopicMetricsClient ¶
type KafkaTopicMetricsClient struct {
// contains filtered or unexported fields
}
KafkaTopicMetricsClient is used to call kafka to get metrics per client
func (KafkaTopicMetricsClient) GetCustomMetric ¶
func (c KafkaTopicMetricsClient) GetCustomMetric(request MetricRequest, metricSelector labels.Selector) (float64, error)
GetCustomMetric calls kafka to retrieve the value of the metric requested
type MetricRequest ¶
type MetricRequest struct {
// contains filtered or unexported fields
}
MetricRequest represents options
func NewMetricRequest ¶
func NewMetricRequest(info provider.CustomMetricInfo, namespacedname types.NamespacedName) MetricRequest
NewMetricRequest creates a new metric request with defaults for optional parameters
Source Files
Click to show internal directories.
Click to hide internal directories.