Struct Trace 

pub struct Trace {
    pub block_size: usize,
    pub sessions: Vec<SessionTrace>,
}

Fields

block_size: usize

sessions: Vec<SessionTrace>

Implementations

impl Trace

pub fn from_mooncake(path: &Path, trace_block_size: usize) -> Result<Self>

pub fn from_mooncake_rows( rows: Vec<MooncakeRow>, trace_block_size: usize, ) -> Result<Self>

pub fn from_applied_compute_agentic( path: &Path, trace_block_size: usize, shared_prefix_ratio: f64, num_prefix_groups: usize, ) -> Result<Self>

pub fn synthetic(spec: SyntheticTraceSpec) -> Result<Self>

pub fn validate_for_trace_mode(&self) -> Result<()>

pub fn validate_for_concurrency_mode(&self) -> Result<()>

pub fn normalize_session_starts(self) -> Result<Self>

pub fn speed_up_timing(self, ratio: f64) -> Result<Self>

pub fn rescale_session_start_span(self, duration_ms: u64) -> Result<Self>

pub fn rescale_ready_span(self, duration_ms: u64) -> Result<Self>

pub fn expand_hash_prefix_depth(self, factor: usize) -> Self

pub fn duplicate_hash_space(self, copies: usize) -> Self

pub fn partition_by_session(&self, spec: SessionPartitionSpec) -> Vec<Self>

pub fn to_single_turn_requests(&self) -> Result<Vec<DirectRequest>>

pub fn is_single_turn(&self) -> bool

pub fn to_router_sequences( &self, worker_id: WorkerId, hash_mode: SequenceHashMode, ) -> Result<Vec<RouterSequence>>

pub fn into_trace_driver(self) -> Result<WorkloadDriver>

pub fn into_concurrency_driver( self, max_in_flight: usize, ) -> Result<WorkloadDriver>

pub fn into_trace_driver_with_block_size( self, engine_block_size: usize, ) -> Result<WorkloadDriver>

pub fn into_delta_accumulating_trace_driver_with_block_size( self, engine_block_size: usize, ) -> Result<WorkloadDriver>

pub fn into_concurrency_driver_with_block_size( self, engine_block_size: usize, max_in_flight: usize, ) -> Result<WorkloadDriver>

pub fn into_delta_accumulating_concurrency_driver_with_block_size( self, engine_block_size: usize, max_in_flight: usize, ) -> Result<WorkloadDriver>

Trait Implementations

impl Clone for Trace

fn clone(&self) -> Trace

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Trace

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PartialEq for Trace

fn eq(&self, other: &Trace) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for Trace