func()

in confgenerator/agentmetrics.go [29:103]

• 62 lines of code
• 1 McCabe index (conditional complexity)

func (r AgentSelfMetrics) OTelReceiverPipeline() otel.ReceiverPipeline {
	return otel.ReceiverPipeline{
		Receiver: otel.Component{
			Type: "prometheus",
			Config: map[string]interface{}{
				"config": map[string]interface{}{
					"scrape_configs": []map[string]interface{}{{
						"job_name":        "run-gmp-sidecar-self-metrics",
						"scrape_interval": "1m",
						"static_configs": []map[string]interface{}{{
							"targets": []string{fmt.Sprintf("0.0.0.0:%d", r.Port)},
						}},
						"metric_relabel_configs": []map[string]interface{}{{
							"source_labels": []string{"__address__"},
							"target_label":  "instance",
							"replacement":   fmt.Sprintf("%d", r.Port),
							"action":        "replace",
						}},
					}},
				},
			},
		},
		Processors: []otel.Component{
			otel.MetricsFilter(
				"include",
				"strict",
				"otelcol_process_uptime",
				"otelcol_process_memory_rss",
				"grpc_client_attempt_duration",
				"googlecloudmonitoring_point_count",
			),
			otel.Transform("metric", "metric",
				// create new count metric from histogram metric
				otel.ExtractCountMetric(true, "grpc_client_attempt_duration"),
			),
			otel.MetricsTransform(
				otel.RenameMetric("otelcol_process_uptime", "agent/uptime",
					// change data type from double -> int64
					otel.ToggleScalarDataType,
					otel.AddLabel("version", r.Version),
					// remove service.version label
					otel.AggregateLabels("sum", "version"),
				),
				otel.RenameMetric("otelcol_process_memory_rss", "agent/memory_usage",
					// remove service.version label
					otel.AggregateLabels("sum"),
				),
				otel.RenameMetric("grpc_client_attempt_duration_count", "agent/api_request_count",
					// TODO: below is proposed new configuration for the metrics transform processor
					// ignore any non "google.monitoring" RPCs (note there won't be any other RPCs for now)
					// - action: select_label_values
					//   label: grpc_client_method
					//   value_regexp: ^google\.monitoring
					otel.RenameLabel("grpc_client_status", "state"),
					// delete grpc_client_method dimension & service.version label, retaining only state
					otel.AggregateLabels("sum", "state"),
				),
				otel.RenameMetric("googlecloudmonitoring_point_count", "agent/monitoring/point_count",
					// change data type from double -> int64
					otel.ToggleScalarDataType,
					// Remove service.version label
					otel.AggregateLabels("sum", "status"),
				),
			),
			// Add appropriate resource and metric labels.
			otel.GCPResourceDetector(),
			otel.TransformationMetrics(
				otel.AddMetricLabel("namespace", r.Service),
				otel.AddMetricLabel("cluster", "__run__"),
				otel.PrefixResourceAttribute("service.instance.id", "faas.id", ":"),
			),
			otel.GroupByGMPAttrs(),
		},
	}
}