exporter

Documentation

Index

• Constants
• type KafkaExporter
  • func (k *KafkaExporter) Collect(ch chan<- prometheus.Metric)
  • func (k *KafkaExporter) Describe(ch chan<- *prometheus.Desc)
  • func (k *KafkaExporter) GetInstance() error
  • func (k *KafkaExporter) GetMetric(metricName string)
  • func (k *KafkaExporter) GetMetricMeta()
  • func (k *KafkaExporter) InitGauge()
  • func (k *KafkaExporter) NewClient()

Constants

const (
	PROJECT string = "acs_kafka"
)

Types

type KafkaExporter

type KafkaExporter struct {
	DataPoints []struct {
		InstanceId    string  `json:"instanceId"`
		ConsumerGroup string  `json:"consumerGroup,omitempty"`
		Topic         string  `json:"topic,omitempty"`
		Maximum       float64 `json:"Maximum,omitempty"`
		Value         float64 `json:"Value,omitempty"`
	}
	// contains filtered or unexported fields
}

func (*KafkaExporter) Collect

func (k *KafkaExporter) Collect(ch chan<- prometheus.Metric)

func (*KafkaExporter) Describe

func (k *KafkaExporter) Describe(ch chan<- *prometheus.Desc)

func (*KafkaExporter) GetInstance

func (k *KafkaExporter) GetInstance() error

func (*KafkaExporter) GetMetric

func (k *KafkaExporter) GetMetric(metricName string)

func (*KafkaExporter) GetMetricMeta

func (k *KafkaExporter) GetMetricMeta()

func (*KafkaExporter) InitGauge

func (k *KafkaExporter) InitGauge()

func (*KafkaExporter) NewClient

func (k *KafkaExporter) NewClient()