Class JudgeSpanCollector

Collects OpenTelemetry spans for judge evaluation. Implements SpanProcessor to intercept spans as they complete.

Implements

SpanProcessor

Index

Constructors

Methods

forceFlush getSpansForThread onEnd onStart shutdown

Constructors

constructor

new JudgeSpanCollector(): JudgeSpanCollector
Returns JudgeSpanCollector

Methods

forceFlush

forceFlush(): Promise<void>
Forces to export all finished spans

Returns Promise<void>
Implementation of SpanProcessor.forceFlush
- Defined in src/agents/judge/judge-span-collector.ts:17

getSpansForThread

getSpansForThread(threadId: string): ReadableSpan[]
Retrieves all spans associated with a specific thread.
Parameters
- threadId: string
  The thread identifier to filter spans by
Returns ReadableSpan[]
Array of spans for the given thread
- Defined in src/agents/judge/judge-span-collector.ts:31

onEnd

onEnd(span: ReadableSpan): void
Called when a ReadableSpan is ended, if the span.isRecording() returns true.
Parameters
- span: ReadableSpan
  the Span that just ended.
Returns void
Implementation of SpanProcessor.onEnd
- Defined in src/agents/judge/judge-span-collector.ts:13

onStart

onStart(): void
Called when a Span is started, if the span.isRecording() returns true.

Returns void
Implementation of SpanProcessor.onStart
- Defined in src/agents/judge/judge-span-collector.ts:11

shutdown

shutdown(): Promise<void>
Shuts down the processor. Called when SDK is shut down. This is an opportunity for processor to do any cleanup required.

Returns Promise<void>
Implementation of SpanProcessor.shutdown
- Defined in src/agents/judge/judge-span-collector.ts:21