Avoid publishing invalid metrics

Invalid metrics returned by informers should not be sent around
This commit is contained in:
Hector Sanjuan 2021-12-17 11:57:01 +01:00
parent 3e32a40abf
commit 37f9728f49

View File

@ -296,6 +296,11 @@ func (c *Cluster) sendInformerMetrics(ctx context.Context, informer Informer) (t
}
for _, metric := range metrics {
if metric.Discard() { // do not publish invalid metrics
// the tags informer creates an invalid metric
// when no tags are defined.
continue
}
metric.Peer = c.id
ttl := metric.GetTTL()
if ttl > 0 && (ttl < minTTL || minTTL == 0) {