Use constants from semconv (#9626)

Author: laurit

instrumentation/grpc-1.6/library/src/main/java/io/opentelemetry/instrumentation/grpc/v1_6/GrpcHelper.java

@@ -21,6 +21,7 @@
 import io.opentelemetry.context.Scope;
 import io.opentelemetry.context.propagation.ContextPropagators;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
+import io.opentelemetry.semconv.SemanticAttributes;
 import java.util.concurrent.atomic.AtomicLongFieldUpdater;
 
 final class TracingClientInterceptor implements ClientInterceptor {
@@ -110,9 +111,9 @@ public void sendMessage(REQUEST message) {
       Span span = Span.fromContext(context);
       Attributes attributes =
           Attributes.of(
-              GrpcHelper.MESSAGE_TYPE,
-              "SENT",
-              GrpcHelper.MESSAGE_ID,
+              SemanticAttributes.MESSAGE_TYPE,
+              SemanticAttributes.MessageTypeValues.SENT,
+              SemanticAttributes.MESSAGE_ID,
               MESSAGE_ID_UPDATER.incrementAndGet(this));
       span.addEvent("message", attributes);
     }
@@ -140,9 +141,9 @@ public void onMessage(RESPONSE message) {
         Span span = Span.fromContext(context);
         Attributes attributes =
             Attributes.of(
-                GrpcHelper.MESSAGE_TYPE,
-                "RECEIVED",
-                GrpcHelper.MESSAGE_ID,
+                SemanticAttributes.MESSAGE_TYPE,
+                SemanticAttributes.MessageTypeValues.RECEIVED,
+                SemanticAttributes.MESSAGE_ID,
                 MESSAGE_ID_UPDATER.incrementAndGet(TracingClientCall.this));
         span.addEvent("message", attributes);
         try (Scope ignored = context.makeCurrent()) {

instrumentation/grpc-1.6/library/src/main/java/io/opentelemetry/instrumentation/grpc/v1_6/TracingClientInterceptor.java

@@ -19,6 +19,7 @@
 import io.opentelemetry.context.Context;
 import io.opentelemetry.context.Scope;
 import io.opentelemetry.instrumentation.api.instrumenter.Instrumenter;
+import io.opentelemetry.semconv.SemanticAttributes;
 import java.util.concurrent.atomic.AtomicLongFieldUpdater;
 
 final class TracingServerInterceptor implements ServerInterceptor {
@@ -91,9 +92,9 @@ public void sendMessage(RESPONSE message) {
       Span span = Span.fromContext(context);
       Attributes attributes =
           Attributes.of(
-              GrpcHelper.MESSAGE_TYPE,
-              "SENT",
-              GrpcHelper.MESSAGE_ID,
+              SemanticAttributes.MESSAGE_TYPE,
+              SemanticAttributes.MessageTypeValues.SENT,
+              SemanticAttributes.MESSAGE_ID,
               MESSAGE_ID_UPDATER.incrementAndGet(this));
       span.addEvent("message", attributes);
     }
@@ -122,12 +123,11 @@ final class TracingServerCallListener
 
       @Override
       public void onMessage(REQUEST message) {
-        // TODO(anuraaga): Restore
         Attributes attributes =
             Attributes.of(
-                GrpcHelper.MESSAGE_TYPE,
-                "RECEIVED",
-                GrpcHelper.MESSAGE_ID,
+                SemanticAttributes.MESSAGE_TYPE,
+                SemanticAttributes.MessageTypeValues.RECEIVED,
+                SemanticAttributes.MESSAGE_ID,
                 MESSAGE_ID_UPDATER.incrementAndGet(TracingServerCall.this));
         Span.fromContext(context).addEvent("message", attributes);
         delegate().onMessage(message);