TraceProcessIO

Typed processors for transforming inputs and outputs before they are recorded on a traced run. The type parameters describe what the processors receive:

• [PI] — the type passed to processInputs. Depends on the arity of the traced function:
  • 1-arg ([traceFunction]): the raw input type (e.g. String)
  • 0-arg ([traceSupplier]): Map (empty map)
  • 2-arg ([traceBiFunction]): Pair
  • 3-arg ([traceTriFunction]): Triple
• [PO] — the type passed to processOutputs. For non-streaming functions, this is the raw return type. For streaming functions (when [aggregator] is set), this is the aggregated output type returned by the aggregator — not the stream type itself. When processInputs is set, it replaces the default input serialization entirely. Same for processOutputs.

Example (Kotlin)

val process = TraceProcessIO(
    processInputs = Function { input -> mapOf("query" to input) },
    processOutputs = Function { resp -> mapOf("answer" to resp.text) },
)
val config = TraceConfig(name = "my-run", client = client, processTracedIO = process)

Example (Java)

TraceProcessIO process = TraceProcessIO.builder()
    .processInputs(input -> Map.of("query", input))
    .processOutputs(resp -> Map.of("answer", resp.getText()))
    .build();
TraceConfig config = TraceConfig.builder()
    .name("my-run")
    .client(client)
    .processTracedIO(process)
    .build();