Struct SpawnScheduler 

pub struct SpawnScheduler { /* private fields */ }

Implementations

impl SpawnScheduler

pub fn new(ctx: SpawnContext) -> Self

pub async fn enqueue(&self, job: SpawnJob) -> Result<(), String>

pub async fn enqueue_announced( &self, job: SpawnJob, title: Option<String>, ) -> Result<(), String>

Reserve queue capacity, publish the observable child Start, and only then release the job to the worker. This preserves S→C ordering even when child loading/execution fails immediately.

pub async fn publish_parent_replayable_event( &self, parent_session_id: &str, event: AgentEvent, )

Publish replayable parent-session state through the scheduler’s shared runner/cache/account/broadcast boundary.

Trait Implementations

impl Clone for SpawnScheduler

fn clone(&self) -> SpawnScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.