Struct SpawnScheduler 

pub struct SpawnScheduler { /* private fields */ }

Implementations

impl SpawnScheduler

pub fn supports_native_ticket_budget(&self) -> bool

pub fn set_ticket_service(&self, service: Option<Arc<TicketService>>)

pub async fn validate_required_child_context_route( &self, metadata: &HashMap<String, String>, role: &str, ) -> Result<(), String>

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 enqueue_announced_with_gate( &self, job: SpawnJob, title: Option<String>, gate: Option<&AdmissionGate>, ) -> Result<AdmissionCommit<()>, String>

pub async fn enqueue_announced_for_generation( &self, job: SpawnJob, title: Option<String>, gate: Option<&AdmissionGate>, launch_generation: Option<u64>, ) -> Result<AdmissionCommit<()>, String>

A child action supplies the generation it durably prepared before queue admission. Replayed or cancelled generations cannot borrow a newer explicit retry’s pending status.

pub async fn enqueue_announced_for_generation_checked( &self, job: SpawnJob, title: Option<String>, gate: Option<&AdmissionGate>, launch_generation: Option<u64>, admission_check: Option<&QueueAdmissionCheck>, ) -> Result<AdmissionCommit<()>, String>

Preserve the caller’s live Host deadline/revocation check across queue backpressure. Existing callers retain the unchecked compatibility path.

pub async fn reserve_queue_capacity<'a>( &'a self, gate: Option<&'a AdmissionGate>, ) -> Result<AdmissionCommit<QueueCapacityReservation<'a>>, String>

Reserve backpressure capacity before asynchronous Host preflight. This only reserves a Tokio queue slot: it creates no Task, lease or authority.

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.

pub async fn lock_child_launch(&self, child_id: &str) -> ChildLaunchGuard

pub async fn publish_queued_child_cancellation( &self, parent_id: &str, child_id: &str, )

Trait Implementations

impl Clone for SpawnScheduler

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.