Struct ApplicationRunTime 

pub struct ApplicationRunTime {
    pub Scheduler: Arc<Scheduler>,
    pub Environment: Arc<MountainEnvironment>,
}

A RunTime that uses a high-performance, work-stealing scheduler (Echo) to execute all ActionEffects.

Fields

Scheduler: Arc<Scheduler>

A shared handle to the application’s central scheduler.

Environment: Arc<MountainEnvironment>

A shared handle to the application’s Environment, providing all necessary capabilities.

Implementations

impl ApplicationRunTime

pub fn Create( Scheduler: Arc<Scheduler>, Environment: Arc<MountainEnvironment>, ) -> Self

Creates a new ApplicationRunTime that is powered by an Echo scheduler.

impl ApplicationRunTime

pub async fn RunWithTimeout<TCapabilityProvider, TError, TOutput>( &self, Effect: ActionEffect<Arc<TCapabilityProvider>, TError, TOutput>, timeout: Duration, ) -> Result<TOutput, TError>

where TCapabilityProvider: ?Sized + Send + Sync + 'static, <Self as HasEnvironment>::EnvironmentType: Requires<TCapabilityProvider>, TError: From<CommonError> + Send + Sync + 'static, TOutput: Send + Sync + 'static,

Enhanced effect execution with timeout and recovery.

pub async fn RunWithRetry<TCapabilityProvider, TError, TOutput>( &self, Effect: ActionEffect<Arc<TCapabilityProvider>, TError, TOutput>, max_retries: u32, initial_delay: Duration, ) -> Result<TOutput, TError>

where TCapabilityProvider: ?Sized + Send + Sync + 'static, <Self as HasEnvironment>::EnvironmentType: Requires<TCapabilityProvider>, TError: From<CommonError> + Send + Sync + 'static + Display, TOutput: Send + Sync + 'static,

Execute effect with retry mechanism.

impl ApplicationRunTime

pub async fn Shutdown(&self)

Orchestrates the graceful shutdown of all services.

pub async fn ShutdownWithRecovery(&self) -> Result<(), CommonError>

Enhanced shutdown with comprehensive error handling and recovery.

pub async fn ShutdownCocoonWithRetry(&self) -> Result<(), CommonError>

Shutdown Cocoon with retry mechanism.

pub async fn DisposeTerminalsSafely(&self) -> Result<(), CommonError>

Safely dispose of all active terminals.

pub async fn SaveApplicationState(&self) -> Result<(), CommonError>

Save application state before shutdown.

pub async fn FlushPendingOperations(&self)

Flush any pending operations.

Trait Implementations

impl ApplicationRunTime for ApplicationRunTime

The core integration logic between Common::ActionEffect and Echo::Scheduler.

fn Run<'life0, 'async_trait, TCapabilityProvider, TError, TOutput>( &'life0 self, Effect: ActionEffect<Arc<TCapabilityProvider>, TError, TOutput>, ) -> Pin<Box<dyn Future<Output = Result<TOutput, TError>> + Send + 'async_trait>>

where TCapabilityProvider: ?Sized + Send + Sync + 'static + 'async_trait, <Self as HasEnvironment>::EnvironmentType: Requires<TCapabilityProvider>, TError: From<CommonError> + Send + Sync + 'static + 'async_trait, TOutput: Send + Sync + 'static + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Executes an effect using the environment provided by the runtime.

impl Clone for ApplicationRunTime

fn clone(&self) -> ApplicationRunTime

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl HasEnvironment for ApplicationRunTime

type EnvironmentType = MountainEnvironment

The specific, concrete type of the Environment this struct holds.

fn GetEnvironment(&self) -> Arc<Self::EnvironmentType>

Gets a shared, reference-counted pointer to the environment.

impl Environment for ApplicationRunTime