Add client-side tests for Labeler and MetricAttributesFn

Signed-off-by: Michal Jurecko <michal.jurecko@gmail.com>

Author: michaljurecko

interceptor_test.go

@@ -2857,3 +2857,75 @@ func TestLabelerAndMetricAttributesFnCombined(t *testing.T) {
 			"span should not contain MetricAttributesFn attributes")
 	}
 }
+
+func TestLabelerUnaryClient(t *testing.T) {
+	t.Parallel()
+	metricReader, meterProvider := setupMetrics()
+	spanRecorder := tracetest.NewSpanRecorder()
+	traceProvider := trace.NewTracerProvider(trace.WithSpanProcessor(spanRecorder))
+	customAttrs := []attribute.KeyValue{
+		attribute.String("custom.label", "client-value"),
+	}
+	interceptor, err := NewInterceptor(
+		WithMeterProvider(meterProvider),
+		WithTracerProvider(traceProvider),
+	)
+	require.NoError(t, err)
+	client, _, _ := startServer(t,
+		nil,
+		[]connect.ClientOption{
+			connect.WithInterceptors(interceptor, labelerInterceptor{attrs: customAttrs}),
+		},
+		okayPingServer(),
+	)
+	_, err = client.Ping(context.Background(), requestOfSize(1, 12))
+	require.NoError(t, err)
+	assertMetrics(t, metricReader, expectedMetrics{
+		ClientDuration: true,
+		RequiredAttrs: map[string]attribute.Value{
+			"custom.label": attribute.StringValue("client-value"),
+		},
+	})
+	require.Len(t, spanRecorder.Ended(), 1)
+	for _, attr := range spanRecorder.Ended()[0].Attributes() {
+		assert.NotEqual(t, attribute.Key("custom.label"), attr.Key,
+			"span should not contain labeler attributes")
+	}
+}
+
+func TestMetricAttributesFnUnaryClient(t *testing.T) {
+	t.Parallel()
+	metricReader, meterProvider := setupMetrics()
+	spanRecorder := tracetest.NewSpanRecorder()
+	traceProvider := trace.NewTracerProvider(trace.WithSpanProcessor(spanRecorder))
+	interceptor, err := NewInterceptor(
+		WithMeterProvider(meterProvider),
+		WithTracerProvider(traceProvider),
+		WithMetricAttributesFn(func(_ context.Context, spec connect.Spec) []attribute.KeyValue {
+			return []attribute.KeyValue{
+				attribute.String("fn.procedure", spec.Procedure),
+			}
+		}),
+	)
+	require.NoError(t, err)
+	client, _, _ := startServer(t,
+		nil,
+		[]connect.ClientOption{
+			connect.WithInterceptors(interceptor),
+		},
+		okayPingServer(),
+	)
+	_, err = client.Ping(context.Background(), requestOfSize(1, 12))
+	require.NoError(t, err)
+	assertMetrics(t, metricReader, expectedMetrics{
+		ClientDuration: true,
+		RequiredAttrs: map[string]attribute.Value{
+			"fn.procedure": attribute.StringValue(pingv1connect.PingServicePingProcedure),
+		},
+	})
+	require.Len(t, spanRecorder.Ended(), 1)
+	for _, attr := range spanRecorder.Ended()[0].Attributes() {
+		assert.NotEqual(t, attribute.Key("fn.procedure"), attr.Key,
+			"span should not contain MetricAttributesFn attributes")
+	}
+}