Struct LifecycleLauncher 

pub struct LifecycleLauncher { /* private fields */ }

Production implementation of e1’s launcher port.

Implementations

impl LifecycleLauncher

pub fn new( host_id: HostId, app_paths: AppPaths, diagnostics_root: impl Into<PathBuf>, runner_group_id: u64, timeouts: RecoveryTimeouts, retry: RetryPolicy, ports: LifecyclePorts, ) -> Self

pub async fn recover_startup( &self, policies: &[ScalePolicy], ) -> Result<Vec<ReplacementIntent>, LifecycleError>

Reconcile the entire journal before allowing a launch. Unknown-policy attempts are left untouched rather than being acted on without an ownership proof.

pub async fn supervise( &self, policy: &ScalePolicy, ) -> Result<Vec<ReplacementIntent>, LifecycleError>

Supervise all attempts of one policy during an ordinary poll.

Trait Implementations

impl Debug for LifecycleLauncher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl RunnerLauncher for LifecycleLauncher

fn supervise<'life0, 'life1, 'async_trait>( &'life0 self, policy: &'life1 ScalePolicy, ) -> Pin<Box<dyn Future<Output = Result<Vec<ReplacementIntent>, LaunchFailure>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Reconcile this policy’s existing processes before demand is read and capacity is recomputed. A concluded pre-acceptance attempt thereby becomes an ordinary allocation candidate in this same pass; replacement never bypasses the allocator.

fn attempts<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<RunnerAttempt>, LaunchFailure>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Every attempt this host holds, across every policy, terminal ones included.

fn launch<'life0, 'life1, 'async_trait>( &'life0 self, request: LaunchRequest<'life1>, ) -> Pin<Box<dyn Future<Output = Result<RunnerAttempt, LaunchFailure>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Create exactly one runtime and start one runner, and return the attempt that now exists.

fn clean<'life0, 'async_trait>( &'life0 self, id: AttemptId, ) -> Pin<Box<dyn Future<Output = Result<(), LaunchFailure>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Remove a terminal attempt’s runtime and mark it cleaned.