traffic

Documentation

Index

• func ExtractLabels(metric *dto.Metric) []prompb.Label
• func MetricFamiliesToProtoWriteRequest(metricFamilies map[string]*dto.MetricFamily) *prompb.WriteRequest
• func ScrapeTarget(targetURL string) (string, map[string]*dto.MetricFamily, error)
• func SetPodTargets(pods []*corev1.Pod, targetUrl string) error
• func SetServiceIps(serviceByIp map[string]string, serviceByClusterIp map[string]string, ...) error

Functions

func ExtractLabels

func ExtractLabels(metric *dto.Metric) []prompb.Label

func MetricFamiliesToProtoWriteRequest

func MetricFamiliesToProtoWriteRequest(metricFamilies map[string]*dto.MetricFamily) *prompb.WriteRequest

func ScrapeTarget

func ScrapeTarget(targetURL string) (string, map[string]*dto.MetricFamily, error)

ScrapeTarget scrapes an http endpoint for prometheus metrics

func SetPodTargets

func SetPodTargets(pods []*corev1.Pod, targetUrl string) error

SetPodTargets tells traffic collector which pods to target

func SetServiceIps

func SetServiceIps(
	serviceByIp map[string]string,
	serviceByClusterIp map[string]string,
	targetUrl string,
) error

SetServiceIps tells traffic collector what ips map to what name