custommetrics

Documentation

Index

• Constants
• type KafkaMetricsClient
  • func NewClient(client client.Client) KafkaMetricsClient
• type KafkaTopicMetricsClient
  • func (c KafkaTopicMetricsClient) GetCustomMetric(request MetricRequest, metricSelector labels.Selector) (float64, error)
• type MetricRequest
  • func NewMetricRequest(info provider.CustomMetricInfo, namespacedname types.NamespacedName) MetricRequest

Constants

const (

	//MetricSuffix the suffix of lag metric
	MetricSuffix = "-lag"
)

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) 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