Struct RuntimeHandle 

pub struct RuntimeHandle { /* private fields */ }

Implementations

impl RuntimeHandle

pub fn new(runtime: LashRuntime) -> RuntimeHandle

pub fn with_live_replay_store( runtime: LashRuntime, live_replay_store: Arc<dyn LiveReplayStore>, ) -> RuntimeHandle

pub fn writer(&self) -> Arc<Mutex<LashRuntime>>

pub fn observe(&self) -> Arc<RuntimeObservation>

pub fn publish_from(&self, runtime: &LashRuntime)

pub fn record_turn_activity(&self, activity: TurnActivity)

pub fn record_queue_changed( &self, kind: SessionQueueEventKind, batch_ids: Vec<String>, )

pub fn record_process_changed( &self, kind: SessionProcessEventKind, process_ids: Vec<String>, )

pub fn current_session_observation(&self) -> SessionObservation

pub fn resume_session_observation( &self, cursor: &SessionCursor, ) -> Result<SessionResume, LiveReplayStoreError>

pub fn subscribe_session_observation( &self, cursor: &SessionCursor, ) -> Result<SessionObservationSubscription, LiveReplayStoreError>

pub async fn enqueue_turn_input( &self, input: TurnInput, ingress: TurnInputIngress, source_key: Option<String>, ) -> Result<PendingTurnInput, RuntimeError>

pub async fn cancel_pending_turn_input( &self, session_id: &str, input_id: &str, ) -> Result<PendingTurnInputCancelOutcome, RuntimeError>

pub async fn cancel_pending_turn_inputs( &self, session_id: &str, targets: &[PendingTurnInputCancelTarget], ) -> Result<Vec<PendingTurnInputCancelResult>, RuntimeError>

pub async fn cancel_pending_turn_input_suffix( &self, session_id: &str, anchor: &PendingTurnInputCancelTarget, ) -> Result<PendingTurnInputSuffixCancelOutcome, RuntimeError>

pub async fn abandon_queued_work_claim( &self, claim: &QueuedWorkClaim, ) -> Result<(), RuntimeError>

Release a held queued-work claim without completing it, returning its batches to the pending queue immediately.

This is the host lever behind stopping an external queued-work driver mid-claim: instead of letting the claim age out over its lease TTL, the host hands the claim back and the work becomes claimable again at once.

pub async fn abandon_turn_input_claim( &self, claim: &TurnInputClaim, ) -> Result<(), RuntimeError>

Release a held pending-turn-input claim without completing it, returning its inputs to the pending queue immediately. The turn-input counterpart of abandon_queued_work_claim.

pub async fn cancel_queued_work_batch( &self, session_id: &str, batch_id: &str, ) -> Result<Option<QueuedWorkBatch>, RuntimeError>

pub fn try_into_runtime(self) -> Result<LashRuntime, RuntimeHandle>

Trait Implementations

impl Clone for RuntimeHandle

fn clone(&self) -> RuntimeHandle

Returns a duplicate of the value.

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

Performs copy-assignment from source.