Suppress instrumentation based on suppress Context key

instrumentation-api/src/main/java/io/opentelemetry/instrumentation/api/instrumenter/InstrumenterBuilder.java

@@ -354,7 +354,8 @@ private String getSchemaUrl() {
   }
 
   SpanSuppressor buildSpanSuppressor() {
-    return spanSuppressionStrategy.create(getSpanKeysFromAttributesExtractors());
+    return new SpanSuppressors.ByContextKey(
+        spanSuppressionStrategy.create(getSpanKeysFromAttributesExtractors()));
   }
 
   private Set<SpanKey> getSpanKeysFromAttributesExtractors() {

instrumentation-api/src/main/java/io/opentelemetry/instrumentation/api/instrumenter/SpanSuppressors.java

@@ -9,8 +9,10 @@
 import io.opentelemetry.api.trace.Span;
 import io.opentelemetry.api.trace.SpanKind;
 import io.opentelemetry.context.Context;
+import io.opentelemetry.context.ContextKey;
 import io.opentelemetry.instrumentation.api.internal.SpanKey;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Set;
 
 final class SpanSuppressors {
@@ -85,4 +87,28 @@ public boolean shouldSuppress(Context parentContext, SpanKind spanKind) {
       return true;
     }
   }
+
+  static class ByContextKey implements SpanSuppressor {
+    private final SpanSuppressor delegate;
+    static final ContextKey<Boolean> SUPPRESS_INSTRUMENTATION =
+        ContextKey.named(
+            "suppress_instrumentation"); // todo must use the key defined in the Java SDK.
+
+    ByContextKey(SpanSuppressor delegate) {
+      this.delegate = delegate;
+    }
+
+    @Override
+    public Context storeInContext(Context context, SpanKind spanKind, Span span) {
+      return delegate.storeInContext(context, spanKind, span);
+    }
+
+    @Override
+    public boolean shouldSuppress(Context parentContext, SpanKind spanKind) {
+      if (Objects.equals(parentContext.get(SUPPRESS_INSTRUMENTATION), true)) {
+        return true;
+      }
+      return delegate.shouldSuppress(parentContext, spanKind);
+    }
+  }
 }

instrumentation-api/src/test/java/io/opentelemetry/instrumentation/api/instrumenter/SpanSuppressionStrategyTest.java

@@ -5,6 +5,7 @@
 
 package io.opentelemetry.instrumentation.api.instrumenter;
 
+import static io.opentelemetry.instrumentation.api.instrumenter.SpanSuppressors.ByContextKey.SUPPRESS_INSTRUMENTATION;
 import static java.util.Arrays.asList;
 import static java.util.Collections.emptySet;
 import static org.junit.jupiter.api.Assertions.assertEquals;
@@ -157,4 +158,31 @@ void semconv_shouldNotSuppressContextWithPartiallyDifferentSpanKeys() {
 
     assertFalse(suppressor.shouldSuppress(context, SpanKind.SERVER));
   }
+
+  @Test
+  void context_shouldSuppressWhenKeyIsAvailableAndTrue() {
+    Context context = Context.current().with(SUPPRESS_INSTRUMENTATION, true);
+    SpanSuppressor suppressor =
+        new SpanSuppressors.ByContextKey(SpanSuppressionStrategy.NONE.create(emptySet()));
+
+    assertTrue(suppressor.shouldSuppress(context, SpanKind.CLIENT));
+  }
+
+  @Test
+  void context_shouldNotSuppressWhenKeyIsAvailableAndFalse() {
+    Context context = Context.current().with(SUPPRESS_INSTRUMENTATION, false);
+    SpanSuppressor suppressor =
+        new SpanSuppressors.ByContextKey(SpanSuppressionStrategy.NONE.create(emptySet()));
+
+    assertFalse(suppressor.shouldSuppress(context, SpanKind.CLIENT));
+  }
+
+  @Test
+  void context_shouldNotSuppressWhenKeyIsNotAvailable() {
+    Context context = Context.current();
+    SpanSuppressor suppressor =
+        new SpanSuppressors.ByContextKey(SpanSuppressionStrategy.NONE.create(emptySet()));
+
+    assertFalse(suppressor.shouldSuppress(context, SpanKind.CLIENT));
+  }
 }