Package ai.acolite.agentsdk.core.tracing

Class BatchTraceProcessor

java.lang.Object

ai.acolite.agentsdk.core.tracing.BatchTraceProcessor

All Implemented Interfaces:

TraceProcessor, AutoCloseable

public class BatchTraceProcessor
extends Object
implements TraceProcessor

BatchTraceProcessor

Buffers traces and spans in memory and exports them in batches. Provides configurable batching behavior with automatic and manual flush.

Key Features: - In-memory buffering with bounded queue - Periodic batch export (every N seconds) - Threshold-based export (when queue is 80% full) - Graceful shutdown with final flush - Thread-safe operations

Thread Safety: - BlockingQueue handles concurrent enqueue from multiple threads - Synchronized exportBatch() ensures only one export runs at a time - ScheduledExecutorService provides periodic exports on single thread

Usage:

 BatchTraceProcessor processor = new BatchTraceProcessor(
     exporter,
     BatchTraceProcessor.Config.builder()
         .maxBatchSize(100)
         .scheduleDelayMs(5000)
         .build()
 );
 

Source: https://github.com/openai/openai-agents-js/blob/main/packages/agents-core/src/tracing/batcher.ts

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	BatchTraceProcessor.Config	Configuration for BatchTraceProcessor

Constructor Summary

Constructors

Constructor	Description
BatchTraceProcessor(TraceExporter exporter, BatchTraceProcessor.Config config)

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	forceFlush()	Flush all pending traces/spans.
void	onSpanEnd(Span<?> span)	Called when a span ends.
void	onSpanStart(Span<?> span)	Called when a span starts.
void	onTraceEnd(Trace trace)	Called when a trace ends.
void	onTraceStart(Trace trace)	Called when a trace starts.
CompletableFuture<Void>	shutdown(long timeoutMs)	Shutdown the processor gracefully.

Methods inherited from class java.lang.Object

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

Methods inherited from interface ai.acolite.agentsdk.core.tracing.TraceProcessor

close, shutdown

Constructor Details

BatchTraceProcessor

public BatchTraceProcessor(TraceExporter exporter,
 BatchTraceProcessor.Config config)

Method Details

onTraceStart

public void onTraceStart(Trace trace)

Description copied from interface: TraceProcessor

Called when a trace starts. Processors can export the trace immediately or buffer it.

Specified by:

onTraceStart in interface TraceProcessor

onTraceEnd

public void onTraceEnd(Trace trace)

Description copied from interface: TraceProcessor

Called when a trace ends.

Specified by:

onTraceEnd in interface TraceProcessor

onSpanStart

public void onSpanStart(Span<?> span)

Description copied from interface: TraceProcessor

Called when a span starts.

Specified by:

onSpanStart in interface TraceProcessor

onSpanEnd

public void onSpanEnd(Span<?> span)

Description copied from interface: TraceProcessor

Called when a span ends. Most processors export spans on end to capture complete data.

Specified by:

onSpanEnd in interface TraceProcessor

forceFlush

public CompletableFuture<Void> forceFlush()

Description copied from interface: TraceProcessor

Flush all pending traces/spans. Blocks until all data is exported.

Specified by:

forceFlush in interface TraceProcessor

shutdown

public CompletableFuture<Void> shutdown(long timeoutMs)

Description copied from interface: TraceProcessor

Shutdown the processor gracefully. Flushes pending data and releases resources.

Specified by:

shutdown in interface TraceProcessor

Parameters:

timeoutMs - Maximum time to wait for shutdown (milliseconds)