程序包 com.agentsflex.core.model.chat

类 ChatObservabilityInterceptor

java.lang.Object

com.agentsflex.core.model.chat.ChatObservabilityInterceptor

所有已实现的接口:

ChatInterceptor

public class ChatObservabilityInterceptor
extends Object
implements ChatInterceptor

字段概要

字段

修饰符和类型	字段	说明
private static final io.opentelemetry.api.metrics.LongCounter	LLM_ERROR_COUNT
private static final io.opentelemetry.api.metrics.DoubleHistogram	LLM_LATENCY_HISTOGRAM
private static final io.opentelemetry.api.metrics.LongCounter	LLM_REQUEST_COUNT
private static final int	MAX_RESPONSE_LENGTH_FOR_SPAN
private static final io.opentelemetry.api.metrics.Meter	METER
private static final io.opentelemetry.api.trace.Tracer	TRACER

构造器概要

构造器

构造器	说明
ChatObservabilityInterceptor()

方法概要

修饰符和类型	方法	说明
private void	enrichSpan(io.opentelemetry.api.trace.Span span, AiMessage msg)
AiMessageResponse	intercept(BaseChatModel<?> chatModel, ChatContext context, SyncChain chain)	拦截同步聊天请求。
void	interceptStream(BaseChatModel<?> chatModel, ChatContext context, StreamResponseListener originalListener, StreamChain chain)	拦截流式聊天请求。
private void	recordError(io.opentelemetry.api.trace.Span span, Exception e, String provider, String model, String operation, long startTimeNanos)
private void	recordMetrics(String provider, String model, String operation, boolean success, long startTimeNanos)

从类继承的方法 java.lang.Object

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

字段详细资料

TRACER

private static final io.opentelemetry.api.trace.Tracer TRACER

METER

private static final io.opentelemetry.api.metrics.Meter METER

LLM_REQUEST_COUNT

private static final io.opentelemetry.api.metrics.LongCounter LLM_REQUEST_COUNT

LLM_LATENCY_HISTOGRAM

private static final io.opentelemetry.api.metrics.DoubleHistogram LLM_LATENCY_HISTOGRAM

LLM_ERROR_COUNT

private static final io.opentelemetry.api.metrics.LongCounter LLM_ERROR_COUNT

MAX_RESPONSE_LENGTH_FOR_SPAN

private static final int MAX_RESPONSE_LENGTH_FOR_SPAN

另请参阅:

• 常量字段值

构造器详细资料

ChatObservabilityInterceptor

public ChatObservabilityInterceptor()

方法详细资料

intercept

public AiMessageResponse intercept(BaseChatModel<?> chatModel,
 ChatContext context,
 SyncChain chain)

从接口复制的说明: ChatInterceptor

拦截同步聊天请求。

指定者:

intercept 在接口中 ChatInterceptor

interceptStream

public void interceptStream(BaseChatModel<?> chatModel,
 ChatContext context,
 StreamResponseListener originalListener,
 StreamChain chain)

从接口复制的说明: ChatInterceptor

拦截流式聊天请求。

指定者:

interceptStream 在接口中 ChatInterceptor

enrichSpan

private void enrichSpan(io.opentelemetry.api.trace.Span span,
 AiMessage msg)

recordMetrics

private void recordMetrics(String provider,
 String model,
 String operation,
 boolean success,
 long startTimeNanos)

recordError

private void recordError(io.opentelemetry.api.trace.Span span,
 Exception e,
 String provider,
 String model,
 String operation,
 long startTimeNanos)