Struct RequestGenerator 

pub struct RequestGenerator { /* private fields */ }

Generates requests based on workload configuration

Implementations

impl RequestGenerator

pub fn new(workload: WorkloadConfig) -> Self

pub fn from_dataset<I>( workload: WorkloadConfig, dataset_iterator: I, _total_entries: Option<usize>, tokenizer: BatchTokenizerFn, ) -> Self

where I: Iterator<Item = Result<Option<UnparsedEntry>, Box<dyn Error>>> + Send + 'static,

Create a new generator from a dataset iterator Spawns a background thread to read, parse, and batch-tokenize entries in parallel Buffer size controls memory usage (entries buffered ahead of simulation)

pub fn is_dataset_mode(&self) -> bool

Check if using dataset mode

pub fn peek_next_arrival_time(&self) -> f64

Get the next scheduled arrival time

pub fn next_if_before(&mut self, current_time: f64) -> Option<Request>

Get the next request if its arrival time is before the given time Returns None if no request is ready or all requests have been generated

pub fn is_finished(&self) -> bool

Check if all requests have been generated

pub fn on_request_complete(&mut self, completion_time: f64)

Called when a request completes (for closed-loop pattern) Generates a new request for that “user slot” at the completion time

pub fn num_generated(&self) -> usize

Get number of requests generated so far

pub fn peek_next_arrival(&self) -> f64

Peek at the next arrival time without generating the request