Struct LiveEngine 

pub struct LiveEngine { /* private fields */ }

A running Mocker scheduler with request-scoped output streams.

Implementations

impl LiveEngine

pub fn start(args: MockEngineArgs, dp_rank: u32) -> Result<Self>

Start one live scheduler at dp_rank.

pub async fn submit(&self, request: DirectRequest) -> Result<LiveRequest>

Submit a request and return its scoped output receiver.

pub async fn cancel(&self, request_id: Uuid) -> Result<bool>

Cancel an active request and wait until the scheduler applies it.

pub fn metrics_receiver(&self) -> Receiver<MockerMetrics>

Subscribe to live scheduler occupancy and KV metrics.

pub fn active_request_count(&self) -> usize

Number of response streams currently registered with the dispatcher.

Trait Implementations

impl Clone for LiveEngine

fn clone(&self) -> LiveEngine

Returns a duplicate of the value.

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

Performs copy-assignment from source.