Merge pull request #1028 from iRevive/oteljava/testkit-reset-spans

oteljava: add `TracesTestkit#resetSpans`

Author: iRevive

build.sbt

@@ -1,6 +1,6 @@
 import com.typesafe.tools.mima.core._
 
-ThisBuild / tlBaseVersion := "0.13"
+ThisBuild / tlBaseVersion := "0.14"
 
 ThisBuild / organization := "org.typelevel"
 ThisBuild / organizationName := "Typelevel"

oteljava/testkit/src/main/scala/org/typelevel/otel4s/oteljava/testkit/OtelJavaTestkit.scala

@@ -86,6 +86,7 @@ object OtelJavaTestkit {
     def tracerProvider: TracerProvider[F] = traces.tracerProvider
     def propagators: ContextPropagators[Context] = traces.propagators
     def finishedSpans[A: FromSpanData]: F[List[A]] = traces.finishedSpans
+    def resetSpans: F[Unit] = traces.resetSpans
     def collectMetrics[A: FromMetricData]: F[List[A]] = metrics.collectMetrics
   }
 

oteljava/trace-testkit/src/main/scala/org/typelevel/otel4s/oteljava/testkit/trace/TracesTestkit.scala

@@ -55,11 +55,15 @@ trait TracesTestkit[F[_]] {
     * TracesTestkit[F].finishedSpans[SpanData] // OpenTelemetry Java models
     *   }}}
     *
-    * @note
-    *   each invocation cleans up the internal buffer.
+    * @see
+    *   [[resetSpans]] to reset the internal buffer
     */
   def finishedSpans[A: FromSpanData]: F[List[A]]
 
+  /** Resets the internal buffer.
+    */
+  def resetSpans: F[Unit]
+
   /** The propagators used by the [[org.typelevel.otel4s.trace.TracerProvider TracerProvider]].
     */
   def propagators: ContextPropagators[Context]
@@ -137,6 +141,8 @@ object TracesTestkit {
         result <- Async[F].delay(exporter.getFinishedSpanItems)
       } yield result.asScala.toList.map(FromSpanData[A].from)
 
+    def resetSpans: F[Unit] =
+      Async[F].delay(exporter.reset())
   }
 
 }