Resilience4j 2+

dd-java-agent/instrumentation/resilience4j/resilience4j-2/build.gradle

@@ -0,0 +1,41 @@
+ext {
+  minJavaVersionForTests = JavaVersion.VERSION_17
+}
+
+apply from: "$rootDir/gradle/java.gradle"
+apply plugin: 'idea'
+
+muzzle {
+  pass {
+    group = 'io.github.resilience4j'
+    module = 'resilience4j-all'
+    versions = '[2.0.0,)'
+    assertInverse = true
+    javaVersion = "17"
+  }
+}
+
+idea {
+  module {
+    jdkName = '17'
+  }
+}
+
+// Set all compile tasks to use JDK17 but let instrumentation code target 1.8 compatibility
+project.tasks.withType(AbstractCompile).configureEach {
+  setJavaVersion(it, 17)
+}
+compileJava.configure {
+  sourceCompatibility = JavaVersion.VERSION_1_8
+  targetCompatibility = JavaVersion.VERSION_1_8
+}
+
+addTestSuiteForDir('latestDepTest', 'test')
+
+dependencies {
+  compileOnly group: 'io.github.resilience4j', name: 'resilience4j-all', version: '2.0.0'
+
+  testImplementation group: 'io.github.resilience4j', name: 'resilience4j-all', version: '2.0.0'
+  latestDepTestImplementation group: 'io.github.resilience4j', name: 'resilience4j-all', version: '2.+'
+}
+

dd-java-agent/instrumentation/resilience4j/resilience4j-2/src/main/java/datadog/trace/instrumentation/resilience4j/CircuitBreakerDecorator.java

@@ -0,0 +1,34 @@
+package datadog.trace.instrumentation.resilience4j;
+
+import datadog.trace.api.Config;
+import datadog.trace.bootstrap.instrumentation.api.AgentSpan;
+import io.github.resilience4j.circuitbreaker.CircuitBreaker;
+
+public final class CircuitBreakerDecorator extends Resilience4jSpanDecorator<CircuitBreaker> {
+  public static final CircuitBreakerDecorator DECORATE = new CircuitBreakerDecorator();
+  public static final String TAG_PREFIX = "resilience4j.circuit-breaker.";
+  public static final String TAG_METRICS_PREFIX = TAG_PREFIX + "metrics.";
+
+  private CircuitBreakerDecorator() {
+    super();
+  }
+
+  @Override
+  public void decorate(AgentSpan span, CircuitBreaker data) {
+    span.setTag("resilience4j.circuit_breaker.name", data.getName());
+    span.setTag("resilience4j.circuit_breaker.state", data.getState().toString());
+    if (Config.get().isResilience4jTagMetricsEnabled()) {
+      CircuitBreaker.Metrics ms = data.getMetrics();
+      span.setTag(TAG_METRICS_PREFIX + "failure_rate", ms.getFailureRate());
+      span.setTag(TAG_METRICS_PREFIX + "slow_call_rate", ms.getSlowCallRate());
+      span.setTag(TAG_METRICS_PREFIX + "slow_calls", ms.getNumberOfSlowCalls());
+      span.setTag(
+          TAG_METRICS_PREFIX + "slow_successful_calls", ms.getNumberOfSlowSuccessfulCalls());
+      span.setTag(TAG_METRICS_PREFIX + "slow_failed_calls", ms.getNumberOfSlowFailedCalls());
+      span.setTag(TAG_METRICS_PREFIX + "buffered_calls", ms.getNumberOfBufferedCalls());
+      span.setTag(TAG_METRICS_PREFIX + "failed_calls", ms.getNumberOfFailedCalls());
+      span.setTag(TAG_METRICS_PREFIX + "not_permitted_calls", ms.getNumberOfNotPermittedCalls());
+      span.setTag(TAG_METRICS_PREFIX + "successful_calls", ms.getNumberOfSuccessfulCalls());
+    }
+  }
+}

dd-java-agent/instrumentation/resilience4j/resilience4j-2/src/main/java/datadog/trace/instrumentation/resilience4j/CircuitBreakerInstrumentation.java

@@ -0,0 +1,242 @@
+package datadog.trace.instrumentation.resilience4j;
+
+import static datadog.trace.agent.tooling.bytebuddy.matcher.NameMatchers.named;
+import static net.bytebuddy.matcher.ElementMatchers.isMethod;
+import static net.bytebuddy.matcher.ElementMatchers.isStatic;
+import static net.bytebuddy.matcher.ElementMatchers.returns;
+import static net.bytebuddy.matcher.ElementMatchers.takesArgument;
+
+import com.google.auto.service.AutoService;
+import datadog.trace.agent.tooling.InstrumenterModule;
+import io.github.resilience4j.circuitbreaker.CircuitBreaker;
+import io.github.resilience4j.core.functions.CheckedConsumer;
+import io.github.resilience4j.core.functions.CheckedFunction;
+import io.github.resilience4j.core.functions.CheckedRunnable;
+import io.github.resilience4j.core.functions.CheckedSupplier;
+import java.util.concurrent.Callable;
+import java.util.concurrent.CompletionStage;
+import java.util.concurrent.Future;
+import java.util.function.Consumer;
+import java.util.function.Function;
+import java.util.function.Supplier;
+import net.bytebuddy.asm.Advice;
+
+@AutoService(InstrumenterModule.class)
+public final class CircuitBreakerInstrumentation extends Resilience4jInstrumentation {
+
+  private static final String CIRCUIT_BREAKER_FQCN =
+      "io.github.resilience4j.circuitbreaker.CircuitBreaker";
+
+  private static final String THIS_CLASS = CircuitBreakerInstrumentation.class.getName();
+
+  public CircuitBreakerInstrumentation() {
+    super("resilience4j-circuitbreaker");
+  }
+
+  @Override
+  public String instrumentedType() {
+    return CIRCUIT_BREAKER_FQCN;
+  }
+
+  @Override
+  public void methodAdvice(MethodTransformer transformer) {
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateCheckedSupplier"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(CHECKED_SUPPLIER_FQCN))),
+        THIS_CLASS + "$CheckedSupplierAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateCheckedFunction"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(CHECKED_FUNCTION_FQCN))),
+        THIS_CLASS + "$CheckedFunctionAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateCheckedConsumer"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(CHECKED_CONSUMER_FQCN))),
+        THIS_CLASS + "$CheckedConsumerAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateCompletionStage"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(SUPPLIER_FQCN))),
+        THIS_CLASS + "$CompletionStageAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateFuture"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(SUPPLIER_FQCN))),
+        THIS_CLASS + "$FutureAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateConsumer"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(CONSUMER_FQCN))),
+        THIS_CLASS + "$ConsumerAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateCheckedRunnable"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(CHECKED_RUNNABLE_FQCN))),
+        THIS_CLASS + "$CheckedRunnableAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateCallable"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(CALLABLE_FQCN))),
+        THIS_CLASS + "$CallableAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateRunnable"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(RUNNABLE_FQCN))),
+        THIS_CLASS + "$RunnableAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateSupplier"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(SUPPLIER_FQCN))),
+        THIS_CLASS + "$SupplierAdvice");
+    transformer.applyAdvice(
+        isMethod()
+            .and(isStatic())
+            .and(named("decorateFunction"))
+            .and(takesArgument(0, named(CIRCUIT_BREAKER_FQCN)))
+            .and(returns(named(FUNCTION_FQCN))),
+        THIS_CLASS + "$FunctionAdvice");
+  }
+
+  public static class SupplierAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) Supplier<?> result) {
+      result =
+          new WrapperWithContext.SupplierWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class CallableAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) Callable<?> result) {
+      result =
+          new WrapperWithContext.CallableWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class RunnableAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) Runnable result) {
+      result =
+          new WrapperWithContext.RunnableWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class FunctionAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) Function<?, ?> result) {
+      result =
+          new WrapperWithContext.FunctionWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class CheckedSupplierAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) CheckedSupplier<?> result) {
+      result =
+          new WrapperWithContext.CheckedSupplierWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class CheckedFunctionAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) CheckedFunction<?, ?> result) {
+      result =
+          new WrapperWithContext.CheckedFunctionWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class CheckedConsumerAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) CheckedConsumer<?> result) {
+      result =
+          new WrapperWithContext.CheckedConsumerWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class CheckedRunnableAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) CheckedRunnable result) {
+      result =
+          new WrapperWithContext.CheckedRunnableWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class ConsumerAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) Consumer<?> result) {
+      result =
+          new WrapperWithContext.ConsumerWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class CompletionStageAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) Supplier<CompletionStage<?>> result) {
+      result =
+          new WrapperWithContext.SupplierOfCompletionStageWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+
+  public static class FutureAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.Argument(value = 0) CircuitBreaker circuitBreaker,
+        @Advice.Return(readOnly = false) Supplier<Future<?>> result) {
+      result =
+          new WrapperWithContext.SupplierOfFutureWithContext<>(
+              result, CircuitBreakerDecorator.DECORATE, circuitBreaker);
+    }
+  }
+}

dd-java-agent/instrumentation/resilience4j/resilience4j-2/src/main/java/datadog/trace/instrumentation/resilience4j/FallbackCallableInstrumentation.java

@@ -0,0 +1,44 @@
+package datadog.trace.instrumentation.resilience4j;
+
+import static datadog.trace.agent.tooling.bytebuddy.matcher.NameMatchers.named;
+import static net.bytebuddy.matcher.ElementMatchers.isMethod;
+
+import com.google.auto.service.AutoService;
+import datadog.trace.agent.tooling.InstrumenterModule;
+import io.github.resilience4j.core.functions.CheckedSupplier;
+import java.util.concurrent.Callable;
+import net.bytebuddy.asm.Advice;
+
+@AutoService(InstrumenterModule.class)
+public class FallbackCallableInstrumentation extends Resilience4jInstrumentation {
+  public FallbackCallableInstrumentation() {
+    super("resilience4j-fallback");
+  }
+
+  @Override
+  public String instrumentedType() {
+    return "io.github.resilience4j.decorators.Decorators$DecorateCallable";
+  }
+
+  @Override
+  public void methodAdvice(MethodTransformer transformer) {
+    transformer.applyAdvice(
+        isMethod().and(named("withFallback")),
+        FallbackCallableInstrumentation.class.getName() + "$CallableAdvice");
+  }
+
+  public static class CallableAdvice {
+    @Advice.OnMethodExit(suppress = Throwable.class)
+    public static void afterExecute(
+        @Advice.FieldValue(value = "callable", readOnly = false) Callable<?> callable) {
+      callable =
+          new WrapperWithContext.CallableWithContext<>(
+              callable, Resilience4jSpanDecorator.DECORATE, null);
+    }
+
+    // 2.0.0+
+    public static void muzzleCheck(CheckedSupplier<?> cs) throws Throwable {
+      cs.get();
+    }
+  }
+}