Struct ManagedRuntimeClient 

pub struct ManagedRuntimeClient { /* private fields */ }

Shared durable lifecycle implementation used by provider integrations.

Implementations

impl ManagedRuntimeClient

pub fn new( state: Arc<dyn RuntimeStateStore>, driver: Arc<dyn RuntimeDriver>, ) -> Self

pub fn with_clock( state: Arc<dyn RuntimeStateStore>, driver: Arc<dyn RuntimeDriver>, clock: Arc<dyn RuntimeClock>, ) -> Self

Trait Implementations

impl RuntimeClient for ManagedRuntimeClient

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

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

fn apply<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 RuntimeApplyRequest, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeObservation>> + Send + 'async_trait>>

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

fn inspect<'life0, 'life1, 'async_trait>( &'life0 self, unit_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeInspection>> + Send + 'async_trait>>

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

fn stop<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 RuntimeActionRequest, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeInspection>> + Send + 'async_trait>>

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

fn remove<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 RuntimeActionRequest, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeRemoval>> + Send + 'async_trait>>

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

fn logs<'life0, 'life1, 'async_trait>( &'life0 self, query: &'life1 RuntimeLogQuery, ) -> Pin<Box<dyn Future<Output = RuntimeResult<Vec<RuntimeLogChunk>>> + Send + 'async_trait>>

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

fn exec<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 RuntimeExecRequest, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeExecResult>> + Send + 'async_trait>>

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