Package kimaira.agentic.core.behavior

Class AgenticTracingBehaviorImpl

java.lang.Object
kimaira.agentic.core.behavior.AgenticTracingBehaviorImpl
All Implemented Interfaces:
AgenticTracingBehavior
public class AgenticTracingBehaviorImpl extends Object implements AgenticTracingBehavior

  • Constructor Summary

    Constructors
    Constructor
    Description
    AgenticTracingBehaviorImpl(kimaira.tracing.OpenTelemetryService openTelemetryService)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.opentelemetry.api.trace.Span
    createSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, io.opentelemetry.api.trace.SpanKind spanKind, String name)
     
    io.opentelemetry.api.trace.Span
    createSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, io.opentelemetry.api.trace.SpanKind spanKind, String conversationId, String name)
     
    io.opentelemetry.api.trace.Span
    createSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, String conversationId, String name)
     
    io.opentelemetry.api.trace.Span
    prepareExecutionSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, String name, kimaira.agentic.data.transfer.messaging.Message message)
     
    void
    spanAttributes(io.opentelemetry.api.trace.Span span, String openInferenceInputOutput, kimaira.agentic.data.transfer.messaging.Message message)
     
    void
    traceConsumedMessage(String name, kimaira.agentic.data.transfer.messaging.Message message)
     
    void
    traceMessageExecution(kimaira.agentic.data.transfer.messaging.Message message, io.opentelemetry.api.trace.Span span)
     
    void
    traceMessageSending(String to, String jsonMessage)
     

    Methods inherited from class java.lang.Object

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

  • Constructor Details

    • AgenticTracingBehaviorImpl

      public AgenticTracingBehaviorImpl(kimaira.tracing.OpenTelemetryService openTelemetryService)

  • Method Details

    • createSpan

      public io.opentelemetry.api.trace.Span createSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, io.opentelemetry.api.trace.SpanKind spanKind, String conversationId, String name)
      Specified by:
      createSpan in interface AgenticTracingBehavior

    • createSpan

      public io.opentelemetry.api.trace.Span createSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, io.opentelemetry.api.trace.SpanKind spanKind, String name)
      Specified by:
      createSpan in interface AgenticTracingBehavior

    • createSpan

      public io.opentelemetry.api.trace.Span createSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, String conversationId, String name)
      Specified by:
      createSpan in interface AgenticTracingBehavior

    • spanAttributes

      public void spanAttributes(io.opentelemetry.api.trace.Span span, String openInferenceInputOutput, kimaira.agentic.data.transfer.messaging.Message message)
      Specified by:
      spanAttributes in interface AgenticTracingBehavior

    • prepareExecutionSpan

      public io.opentelemetry.api.trace.Span prepareExecutionSpan(com.arize.semconv.trace.SemanticConventions.OpenInferenceSpanKind inferenceKind, String name, kimaira.agentic.data.transfer.messaging.Message message)
      Specified by:
      prepareExecutionSpan in interface AgenticTracingBehavior

    • traceMessageExecution

      public void traceMessageExecution(kimaira.agentic.data.transfer.messaging.Message message, io.opentelemetry.api.trace.Span span)
      Specified by:
      traceMessageExecution in interface AgenticTracingBehavior

    • traceMessageSending

      public void traceMessageSending(String to, String jsonMessage)
      Specified by:
      traceMessageSending in interface AgenticTracingBehavior

    • traceConsumedMessage

      public void traceConsumedMessage(String name, kimaira.agentic.data.transfer.messaging.Message message)
      Specified by:
      traceConsumedMessage in interface AgenticTracingBehavior