From 617c56f55a14b7f6ed4f0f4402c1e18aaf3b396c Mon Sep 17 00:00:00 2001 From: fcddk <50894443+fcddk@users.noreply.github.com> Date: Thu, 10 Dec 2020 10:30:30 +0800 Subject: [PATCH] add endponits labels metadata add endponits labels metadata Signed-off-by: root --- discovery/kubernetes/endpoints.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/discovery/kubernetes/endpoints.go b/discovery/kubernetes/endpoints.go index f905ae92c..183c729ab 100644 --- a/discovery/kubernetes/endpoints.go +++ b/discovery/kubernetes/endpoints.go @@ -199,6 +199,8 @@ func endpointsSourceFromNamespaceAndName(namespace, name string) string { } const ( + endpointsLabelPrefix = metaLabelPrefix + "endpoints_label_" + endpointsLabelPresentPrefix = metaLabelPrefix + "endpoints_labelpresent_" endpointsNameLabel = metaLabelPrefix + "endpoints_name" endpointNodeName = metaLabelPrefix + "endpoint_node_name" endpointHostname = metaLabelPrefix + "endpoint_hostname" @@ -218,6 +220,12 @@ func (e *Endpoints) buildEndpoints(eps *apiv1.Endpoints) *targetgroup.Group { endpointsNameLabel: lv(eps.Name), } e.addServiceLabels(eps.Namespace, eps.Name, tg) + //add endponits labels metadata + for k, v := range eps.Labels { + ln := strutil.SanitizeLabelName(k) + tg.Labels[model.LabelName(endpointsLabelPrefix+ln)] = lv(v) + tg.Labels[model.LabelName(endpointsLabelPresentPrefix+ln)] = presentValue + } type podEntry struct { pod *apiv1.Pod