beam_audit

beam_audit records what the pipeline did, one event per step that matters.

beam_audit = { path = "../riverbeam/crates/beam_audit" }

Item	Role
AuditAction	request_received, agent_invoked, agent_completed, agent_failed, agent_interrupted, agent_resumed, tool_called, model_routed, quota_checked, quota_exceeded, security_event
AuditEvent	new(action) and builders agent_name, user_id, session_id, run_id, status, error; public model_used, token_usage, latency_ms, metadata fields
AuditSink	Trait: write(&AuditEvent)
StdoutSink	One JSON line per event
InMemorySink	Keeps events; events()
AuditLogger	new(sinks), with_sink, log(event); writes to each sink in order

There are no feature flags.

The pipeline emits only some of these actions; the list is in Audit.