service name as function input

PeerDB-io · May 6, 2024 · 28c5999 · 28c5999
1 parent 1ae80b2
commit 28c5999
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/flow/cmd/worker.go b/flow/cmd/worker.go
@@ -140,7 +140,7 @@ func WorkerSetup(opts *WorkerSetupOptions) (*workerSetupResponse, error) {
 	var metricsProvider *sdkmetric.MeterProvider
 	var otelManager *otel_metrics.OtelManager
 	if opts.EnableOtelMetrics {
-		metricsProvider, err = otel_metrics.SetupOtelMetricsExporter()
+		metricsProvider, err = otel_metrics.SetupOtelMetricsExporter("flow-worker")
 		if err != nil {
 			return nil, err
 		}

diff --git a/flow/otel_metrics/otel_manager.go b/flow/otel_metrics/otel_manager.go
@@ -32,15 +32,15 @@ func newOtelResource(otelServiceName string) (*resource.Resource, error) {
 	return r, err
 }
 
-func SetupOtelMetricsExporter() (*sdkmetric.MeterProvider, error) {
+func SetupOtelMetricsExporter(otelServiceName string) (*sdkmetric.MeterProvider, error) {
 	metricExporter, err := otlpmetrichttp.New(context.Background(),
 		otlpmetrichttp.WithCompression(otlpmetrichttp.GzipCompression),
 	)
 	if err != nil {
 		return nil, fmt.Errorf("failed to create OpenTelemetry metrics exporter: %w", err)
 	}
 
-	resource, err := newOtelResource("flow-worker")
+	resource, err := newOtelResource(otelServiceName)
 	if err != nil {
 		return nil, fmt.Errorf("failed to create OpenTelemetry resource: %w", err)
 	}