Package com.google.genkit

Class LocalTelemetryStore

java.lang.Object
com.google.genkit.LocalTelemetryStore
All Implemented Interfaces:
io.opentelemetry.sdk.trace.SpanProcessor, Closeable, AutoCloseable
public class LocalTelemetryStore extends Object implements io.opentelemetry.sdk.trace.SpanProcessor
A SpanProcessor that stores traces locally for the Dev UI to access. This enables the evaluation workflow to retrieve trace data including input and output values.

  • Constructor Summary

    Constructors
    Constructor
    Description
    LocalTelemetryStore()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.opentelemetry.sdk.common.CompletableResultCode
    forceFlush()
     
    boolean
    isEndRequired()
     
    boolean
    isStartRequired()
     
    void
    onEnd(io.opentelemetry.sdk.trace.ReadableSpan span)
     
    void
    onStart(io.opentelemetry.context.Context parentContext, io.opentelemetry.sdk.trace.ReadWriteSpan span)
     
    io.opentelemetry.sdk.common.CompletableResultCode
    shutdown()
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface io.opentelemetry.sdk.trace.SpanProcessor

    close

  • Constructor Details

    • LocalTelemetryStore

      public LocalTelemetryStore()

  • Method Details

    • onStart

      public void onStart(io.opentelemetry.context.Context parentContext, io.opentelemetry.sdk.trace.ReadWriteSpan span)
      Specified by:
      onStart in interface io.opentelemetry.sdk.trace.SpanProcessor

    • isStartRequired

      public boolean isStartRequired()
      Specified by:
      isStartRequired in interface io.opentelemetry.sdk.trace.SpanProcessor

    • onEnd

      public void onEnd(io.opentelemetry.sdk.trace.ReadableSpan span)
      Specified by:
      onEnd in interface io.opentelemetry.sdk.trace.SpanProcessor

    • isEndRequired

      public boolean isEndRequired()
      Specified by:
      isEndRequired in interface io.opentelemetry.sdk.trace.SpanProcessor

    • shutdown

      public io.opentelemetry.sdk.common.CompletableResultCode shutdown()
      Specified by:
      shutdown in interface io.opentelemetry.sdk.trace.SpanProcessor

    • forceFlush

      public io.opentelemetry.sdk.common.CompletableResultCode forceFlush()
      Specified by:
      forceFlush in interface io.opentelemetry.sdk.trace.SpanProcessor