Trait Runtime 

pub trait Runtime:
    Send
    + Sync
    + 'static {
    // Required method
    fn spawn<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<Box<dyn WorkerHandle>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;

    // Provided methods
    fn warmup<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
    fn reload<'life0, 'async_trait>(
        &'life0 self,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait { ... }
}

Spawns workers per a runtime-specific strategy.

Required Methods

fn spawn<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn WorkerHandle>>> + Send + 'async_trait>>

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

Spawn a single worker and return a handle.

The caller must call ready() before dispatching requests.

Provided Methods

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

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

Warm up shared caches (OPcache) before spawning workers. Called once at startup. Default: no-op.

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

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

Invalidate compiled-code caches so respawned workers pick up changes.

Called by the dev-mode file watcher just before workers are recycled. In ZTS the OPcache is shared process-wide, so a single reset affects every worker thread. Default: no-op.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl Runtime for MockRuntime