llm

type FileSink struct {
	// contains filtered or unexported fields
}

type Metadata struct {
	TraceID, SessionKey string
	Depth               int
	PricingKnown        bool
}

type MultiSink []Sink

type Sink interface {
	Record(TraceRecord)
}

type SinkFunc func(TraceRecord)

type TraceRecord struct {
	// NativeTrace holds the authoritative native request, response, and spans.
	// Messages and Response remain a display projection for legacy consumers.
	NativeTrace json.RawMessage `json:"native_trace,omitempty"`
	TraceID     string          `json:"trace_id,omitempty"` // correlation id (the run id), set via WithTraceID
	// SessionKey identifies WHICH agent made the call — the run's own session,
	// or a spawned child's derived session. A parent and its children share one
	// provider and one ctx chain, so without this their calls are one
	// undifferentiated stream. Empty outside a durable run.
	SessionKey string `json:"session_key,omitempty"`
	// Depth is the delegation depth of the caller: 0 for the top-level run.
	Depth     int                `json:"depth,omitempty"`
	Timestamp time.Time          `json:"timestamp"`
	Provider  string             `json:"provider"`
	Model     string             `json:"model"`
	Messages  []protocol.Message `json:"messages"`           // the request sent to the model
	Tools     []string           `json:"tools,omitempty"`    // tool names advertised this turn
	Response  string             `json:"response,omitempty"` // assistant text returned
	// ReasoningBlocks carries opaque provider replay state (for example,
	// Anthropic signed thinking). It is recorded separately from Response so it
	// can be replayed without ever rendering it as user-visible assistant text.
	ReasoningBlocks []protocol.ReasoningBlock `json:"reasoning_blocks,omitempty"`
	ToolCalls       []protocol.ToolCall       `json:"tool_calls,omitempty"` // tool calls the model requested
	StopReason      string                    `json:"stop_reason,omitempty"`
	Usage           protocol.Usage            `json:"usage"` // tokens + computed CostUSD
	LatencyMS       int64                     `json:"latency_ms"`
	Streamed        bool                      `json:"streamed"`
	Err             string                    `json:"error,omitempty"`
}