kubernetes/cluster/images/etcd-version-monitor/etcd-version-monitor.go

var listenAddress …

var metricsPath …

var etcdVersionScrapeURI …

var etcdMetricsScrapeURI …

var scrapeTimeout …

func registerFlags(fs *pflag.FlagSet) { … }

const namespace …

var customMetricRegistry …

var etcdVersion …

var gatherer …

type monitorGatherer …

type exportedMetric …

type rewriteFunc …

func (m *monitorGatherer) Gather() ([]*dto.MetricFamily, error) { … }

func (m *monitorGatherer) rewriteExportedMetrics(metrics map[string]*dto.MetricFamily) ([]*dto.MetricFamily, error) { … }

type EtcdVersion …

// Function for fetching etcd version info and feeding it to the prometheus metric.
func getVersion(lastSeenBinaryVersion *string) error { … }

// Periodically fetches etcd version info.
func getVersionPeriodically(stopCh <-chan struct{ … }

// scrapeMetrics scrapes the prometheus metrics from the etcd metrics URI.
func scrapeMetrics() (map[string]*dto.MetricFamily, error) { … }

func renameMetric(mf *dto.MetricFamily, name string) { … }

func renameLabels(mf *dto.MetricFamily, nameMapping map[string]string) { … }

func filterMetricsByLabels(mf *dto.MetricFamily, labelValues map[string]string) { … }

func groupCounterMetricsByLabels(mf *dto.MetricFamily, names map[string]bool) { … }

func labelsKey(lbls []*dto.LabelPair) string { … }

func deleteLabels(mf *dto.MetricFamily, names map[string]bool) { … }

func identity(mf *dto.MetricFamily) (*dto.MetricFamily, error) { … }

func deepCopyMetricFamily(mf *dto.MetricFamily) *dto.MetricFamily { … }

func deepCopyMetric(m *dto.Metric) *dto.Metric { … }

func deepCopyLabelPair(lp *dto.LabelPair) *dto.LabelPair { … }

func main() { … }