set otel context from bindings when go block is started

deps.edn

@@ -22,6 +22,9 @@
         ch.qos.logback/logback-classic {:mvn/version "1.5.6"}
         org.slf4j/slf4j-api            {:mvn/version "2.0.13"}
 
+        ;; distributed tracing
+        com.github.steffan-westcott/clj-otel-api {:mvn/version "0.2.7"}
+
         ;; Vector math, BM25
         net.mikera/vectorz-clj              {:mvn/version "0.48.0"}
         com.github.rholder/snowball-stemmer {:mvn/version "1.3.0.581.1"}

src/clj/fluree/db/util/async.cljc

@@ -3,8 +3,9 @@
     [fluree.db.util.core :as util]
     [fluree.db.util.log :as log]
     [fluree.db.util.core #?(:clj :refer :cljs :refer-macros) [try* catch*]]
-    [clojure.core.async :refer [go <!] :as async]
-    [clojure.core.async.impl.protocols :as async-protocols])
+    [clojure.core.async :as async]
+    [clojure.core.async.impl.protocols :as async-protocols]
+    #?(:clj [steffan-westcott.clj-otel.context :as otel-context]))
   #?(:cljs (:require-macros [fluree.db.util.async :refer [<? go-try]])))
 
 #?(:clj (set! *warn-on-reflection* true))
@@ -50,6 +51,16 @@
      `(let [[result# ch#] (clojure.core.async/alts!! ~ports ~@opts)]
         [(throw-err result#) ch#])))
 
+#?(:clj
+   (defmacro go
+     "Like go but catches the first thrown error and puts it on the returned channel."
+     [& body]
+     `(if-cljs
+        (cljs.core.async/go
+          (do ~@body))
+        (clojure.core.async/go
+          (otel-context/with-bound-context! ~@body)))))
+
 #?(:clj
    (defmacro go-try
      "Like go but catches the first thrown error and puts it on the returned channel."
@@ -61,7 +72,7 @@
             (catch js/Error e# e#)))
         (clojure.core.async/go
           (try
-            ~@body
+            (otel-context/with-bound-context! ~@body)
             (catch Throwable t# t#))))))
 
 (defn throw-if-exception