Struct ApplicationRunTime 

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

Fields

Scheduler: Arc<Scheduler>

Shared handle to the application’s central scheduler.

Environment: Arc<MountainEnvironment>

Shared handle to the MountainEnvironment capability provider.

Implementations

impl ApplicationRunTime

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

impl ApplicationRunTime

pub async fn RunWithRetry<TCapabilityProvider, TError, TOutput>( &self, Effect: ActionEffect<Arc<TCapabilityProvider>, TError, TOutput>, MaximumRetries: u32, InitialDelay: 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,

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,

impl ApplicationRunTime

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

impl ApplicationRunTime

pub async fn FlushPendingOperations(&self)

impl ApplicationRunTime

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

impl ApplicationRunTime

pub async fn Shutdown(&self)

impl ApplicationRunTime

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

impl ApplicationRunTime

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

Trait Implementations

impl ApplicationRunTime for ApplicationRunTime

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