func()

in components/otelopscol/receiver/varnishreceiver/internal/metadata/generated_metrics.go [933:969]

• 35 lines of code
• 9 McCabe index (conditional complexity)

func (mb *MetricsBuilder) EmitForResource(options ...ResourceMetricsOption) {
	rm := pmetric.NewResourceMetrics()
	ils := rm.ScopeMetrics().AppendEmpty()
	ils.Scope().SetName(ScopeName)
	ils.Scope().SetVersion(mb.buildInfo.Version)
	ils.Metrics().EnsureCapacity(mb.metricsCapacity)
	mb.metricVarnishBackendConnectionCount.emit(ils.Metrics())
	mb.metricVarnishBackendRequestCount.emit(ils.Metrics())
	mb.metricVarnishCacheOperationCount.emit(ils.Metrics())
	mb.metricVarnishClientRequestCount.emit(ils.Metrics())
	mb.metricVarnishClientRequestErrorCount.emit(ils.Metrics())
	mb.metricVarnishObjectCount.emit(ils.Metrics())
	mb.metricVarnishObjectExpired.emit(ils.Metrics())
	mb.metricVarnishObjectMoved.emit(ils.Metrics())
	mb.metricVarnishObjectNuked.emit(ils.Metrics())
	mb.metricVarnishSessionCount.emit(ils.Metrics())
	mb.metricVarnishThreadOperationCount.emit(ils.Metrics())

	for _, op := range options {
		op.apply(rm)
	}
	for attr, filter := range mb.resourceAttributeIncludeFilter {
		if val, ok := rm.Resource().Attributes().Get(attr); ok && !filter.Matches(val.AsString()) {
			return
		}
	}
	for attr, filter := range mb.resourceAttributeExcludeFilter {
		if val, ok := rm.Resource().Attributes().Get(attr); ok && filter.Matches(val.AsString()) {
			return
		}
	}

	if ils.Metrics().Len() > 0 {
		mb.updateCapacity(rm)
		rm.MoveTo(mb.metricsBuffer.ResourceMetrics().AppendEmpty())
	}
}