Package com.google.genkit.core.tracing

Class TelemetryServerExporter

java.lang.Object
com.google.genkit.core.tracing.TelemetryServerExporter
All Implemented Interfaces:
io.opentelemetry.sdk.trace.SpanProcessor, Closeable, AutoCloseable
public class TelemetryServerExporter extends Object implements io.opentelemetry.sdk.trace.SpanProcessor
OpenTelemetry SpanProcessor that exports spans to the Genkit telemetry server. This enables traces to be visible in the Genkit Developer UI.

  • Constructor Summary

    Constructors
    Constructor
    Description
    TelemetryServerExporter()
    Creates a new TelemetryServerExporter.

  • Method Summary

    Modifier and Type
    Method
    Description
    io.opentelemetry.sdk.common.CompletableResultCode
    forceFlush()
     
    boolean
    isConfigured()
    Returns true if the exporter is configured with a client.
    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)
     
    void
    setClient(TelemetryClient client)
    Sets the telemetry client to use for exporting traces.
    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

    • TelemetryServerExporter

      public TelemetryServerExporter()
      Creates a new TelemetryServerExporter.

  • Method Details

    • setClient

      public void setClient(TelemetryClient client)
      Sets the telemetry client to use for exporting traces.
      Parameters:
      client - the telemetry client

    • isConfigured

      public boolean isConfigured()
      Returns true if the exporter is configured with a client.

    • 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