chore: misc OTEL refactorings to use CEL based sampler

Author: sureshg

README.md

@@ -56,11 +56,11 @@ The next version will be based on the semantic version scope (`major`, `minor`,
   $ ./gradlew :shared:jvmRun
   $ ./gradlew :shared:jvmDistZip
 
-  # Kotlin JVM
+  # Kotlin JVM (--no-parallel is required until we have fix for kotlin wasm plugin)
   $ ./gradlew :backend:jvm:run
-  $ ./gradlew :backend:jvm:build
-  $ ./gradlew :backend:jvm:jdeprscan
-  $ ./gradlew :backend:jvm:printModuleDeps
+  $ ./gradlew :backend:jvm:build --no-parallel
+  $ ./gradlew :backend:jvm:jdeprscan --no-parallel
+  $ ./gradlew :backend:jvm:printModuleDeps --no-parallel
 
   # Benchmark
   $ ./gradlew :benchmark:benchmark
@@ -95,7 +95,7 @@ The next version will be based on the semantic version scope (`major`, `minor`,
            openjdk:26-slim /bin/bash -c "printenv && backend/jvm/build/libs/jvm"
 
    # Build a container image and run
-   $ ./gradlew :backend:jvm:jibDockerBuild
+   $ ./gradlew :backend:jvm:jibDockerBuild --no-parallel
    $ docker run -it --rm --name jvm -p 8080:8080 -p 9898:9898 sureshg/jvm
    $ docker stats
   ```
@@ -116,7 +116,7 @@ The next version will be based on the semantic version scope (`major`, `minor`,
             -p 4318:4318 \
             --name hyperdx \
             --ulimit nofile=262144:262144 \
-             hyperdx/hyperdx-local:2-beta
+             hyperdx/hyperdx-local:latest
    $ open http://localhost:8081/search
 
    # Run the app

backend/agent/otel/build.gradle.kts

@@ -83,6 +83,7 @@ dependencies {
   compileOnly(libs.bundles.otel.agent.extn)
   compileOnly(libs.google.auto.annotations)
   implementation(libs.otel.contrib.samplers)
+  implementation(libs.otel.contrib.cel.sampler)
   annotationProcessor(libs.google.auto.service.apt)
 
   testImplementation(platform(libs.junit.bom))

backend/jvm/build.gradle.kts

@@ -12,7 +12,7 @@ plugins {
   id("dev.suresh.plugin.graalvm")
   id("com.gradleup.shadow")
   alias(libs.plugins.jetbrains.ktor)
-  // alias(libs.plugins.exoquery)
+  alias(libs.plugins.exoquery)
   id("dev.suresh.plugin.publishing")
   // alias(libs.plugins.jetbrains.exposed)
 }
@@ -210,7 +210,8 @@ dependencies {
   implementation(libs.ktor.server.html)
 
   // OpenTelemetry
-  javaAgent(projects.backend.agent.otel)
+  // javaAgent(projects.backend.agent.otel)
+  javaAgent(libs.otel.instr.javaagent)
   javaAgent(layout.files("src/main/resources/otel"))
   implementation(libs.bundles.otel)
   implementation(libs.ktor.cohort.core)

backend/jvm/src/main/kotlin/dev/suresh/plugins/OTel.kt

@@ -18,8 +18,8 @@ fun Application.configureOTel() {
   val globalOtel = GlobalOpenTelemetry.get()
   val isAgentActive = globalOtel !== OpenTelemetry.noop()
   when (isAgentActive) {
-    true -> log.info("OTel Java agent is active")
-    else -> log.warn("OTel Java agent is inactive!!")
+    true -> log.info("\uD83D\uDFE2 OTel Java agent is active")
+    else -> log.warn("\uD83D\uDFE1 OTel Java agent is inactive!!")
   }
 
   install(OTelExtnPlugin) { enabled = true }
@@ -58,12 +58,12 @@ fun Application.otelInstrumentation() {
  * For detailed configuration options, see:
  * [Configure the SDK](https://opentelemetry.io/docs/languages/java/configuration/)
  */
-val declarativeOtelSdk: OpenTelemetry by lazy {
+val dclOpenTelemetrySdk: OpenTelemetry by lazy {
   val sdkConfPath = System.getenv("OTEL_CONFIG_FILE")?.takeIf { it.isNotBlank() }?.let { Path(it) }
   val ins =
       when (sdkConfPath) {
         null -> object {}::class.java.getResourceAsStream("/otel/sdk-config.yaml")
         else -> sdkConfPath.inputStream()
       }
-  TODO("DeclarativeConfiguration.parseAndCreate(ins)")
+  TODO("FileConfiguration.parseAndCreate(ins)")
 }

backend/jvm/src/main/kotlin/dev/suresh/routes/Scheduler.kt

@@ -14,7 +14,7 @@ import kotlinx.datetime.toLocalDateTime
 fun Application.scheduledTasks() {
   log.info("Starting scheduled tasks...")
   virtualThreadScope.launch {
-    Clock.System.fixedPeriodPulse(10.seconds).beat(PulseBackpressureStrategy.SkipNext) { scheduled
+    Clock.System.fixedPeriodPulse(30.seconds).beat(PulseBackpressureStrategy.SkipNext) { scheduled
       ->
       context(log) { task("Task at ${scheduled.toLocalDateTime(TimeZone.currentSystemDefault())}") }
     }