Method CollectMetrics

modules/generator/registry/registry.go:234–281

(ctx context.Context)

}

func (r *ManagedRegistry) CollectMetrics(ctx context.Context) {
	r.metricsMtx.RLock()
	defer r.metricsMtx.RUnlock()

	var err error
	var seriesDemand int

	for _, m := range r.metrics {
		seriesDemand += m.countSeriesDemand()
	}

	r.metricSeriesDemand.Set(float64(seriesDemand))
	r.metricEntityDemand.Set(float64(r.entityDemand.Estimate()))

	if r.overrides.MetricsGeneratorDisableCollection(r.tenant) {
		return
	}

	defer func() {
		r.metricTotalCollections.Inc()
		if err != nil {
			errT := getErrType(err)
			level.Error(r.logger).Log("msg", "collecting metrics failed", "err", err)
			metricFailedCollections.WithLabelValues(r.tenant, errT).Inc()
		}
	}()

	appender := r.appendable.Appender(ctx)
	collectionTimeMs := time.Now().UnixMilli()

	for _, m := range r.metrics {
		if err = m.collectMetrics(appender, collectionTimeMs); err != nil {
			return
		}
	}

	// Try to avoid committing after we have started the shutdown process.
	if ctx.Err() != nil { // shutdown
		return
	}

	// If the shutdown has started here, a "file already closed" error will be
	// observed here.
	err = appender.Commit()
	if err != nil {
		return
	}
}

func (r *ManagedRegistry) collectionInterval() time.Duration {
	interval := r.overrides.MetricsGeneratorCollectionInterval(r.tenant)