mod arrival;
mod driver;
mod dynamo;
mod trace;
mod types;
use rand::Rng;
use rand::rngs::StdRng;
pub use driver::WorkloadDriver;
pub use dynamo::DynamoRequestTrace;
pub use trace::{AgenticGraphBuilder, load_agentic_mooncake, validate_trace_files};
#[doc(hidden)]
pub use types::CompactReadyTurn;
pub use types::{
AGENTIC_MOONCAKE_SCHEMA, AGENTIC_MOONCAKE_VERSION, AgenticDependency,
AgenticDependencyRelation, AgenticDependencyTrigger, AgenticGraphIdentity, AgenticHashIdScope,
AgenticMooncakeHeader, AgenticMooncakeRow, AgenticNode, AgenticPlay, AgenticSourceProvenance,
AgenticTrace, AgenticTrajectorySnapshot, ArrivalSpec, DelaySpec, LengthSpec, MooncakeRow,
OUTPUT_REPLAY_CONSUMER_RUNTIME_KEY, OUTPUT_REPLAY_ID_ANNOTATION_KEY, ReadyTurn,
ReplayRequestHashes, ReplayRequestPayload, SessionPartitionSpec, SessionTrace,
SyntheticTraceSpec, Trace, TraceFileFormat, TurnTrace, ValidatedAgenticGraph,
effective_replay_key, output_replay_id_annotation,
};
pub(super) const SYNTHETIC_OUTPUT_SEED: u64 = 0xD37A_0A7E_5EED;
pub(super) fn planned_output_token_ids(
authored: Option<Vec<u32>>,
max_output_tokens: usize,
output_rng: &mut StdRng,
) -> Vec<u32> {
authored.unwrap_or_else(|| {
(0..max_output_tokens)
.map(|_| output_rng.random::<u32>())
.collect()
})
}
#[cfg(test)]
mod tests;