Skip to main content

RuntimeStateStore

a3s_runtime

Trait RuntimeStateStore 

Source 
pub trait RuntimeStateStore: Send + Sync {
    // Required methods
    fn acquire_operation_lease<'life0, 'life1, 'async_trait>(
        &'life0 self,
        unit_id: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<Box<dyn RuntimeOperationLease>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn reserve_apply<'life0, 'life1, 'async_trait>(
        &'life0 self,
        request: &'life1 RuntimeApplyRequest,
        now_ms: u64,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeStateReservation>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn reserve_action<'life0, 'life1, 'async_trait>(
        &'life0 self,
        kind: RuntimeActionKind,
        request: &'life1 RuntimeActionRequest,
        now_ms: u64,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeStateReservation>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn reserve_exec<'life0, 'life1, 'async_trait>(
        &'life0 self,
        request: &'life1 RuntimeExecRequest,
        now_ms: u64,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeStateReservation>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn load<'life0, 'life1, 'async_trait>(
        &'life0 self,
        unit_id: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeUnitRecord>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn load_request<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        unit_id: &'life1 str,
        request_id: &'life2 str,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeRequestReceipt>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn update_observation<'life0, 'life1, 'life2, 'async_trait>(
        &'life0 self,
        request_id: Option<&'life1 str>,
        observation: &'life2 RuntimeObservation,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeUnitRecord>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait,
             'life2: 'async_trait;
    fn complete_removal<'life0, 'life1, 'async_trait>(
        &'life0 self,
        removal: &'life1 RuntimeRemoval,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeUnitRecord>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
    fn complete_exec<'life0, 'life1, 'async_trait>(
        &'life0 self,
        result: &'life1 RuntimeExecResult,
    ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeUnitRecord>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Required Methods§

Source

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

Source

fn reserve_apply<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 RuntimeApplyRequest, now_ms: u64, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeStateReservation>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source

fn reserve_action<'life0, 'life1, 'async_trait>( &'life0 self, kind: RuntimeActionKind, request: &'life1 RuntimeActionRequest, now_ms: u64, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeStateReservation>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source

fn reserve_exec<'life0, 'life1, 'async_trait>( &'life0 self, request: &'life1 RuntimeExecRequest, now_ms: u64, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeStateReservation>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source

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

Source

fn load_request<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, unit_id: &'life1 str, request_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeRequestReceipt>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Source

fn update_observation<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, request_id: Option<&'life1 str>, observation: &'life2 RuntimeObservation, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeUnitRecord>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Source

fn complete_removal<'life0, 'life1, 'async_trait>( &'life0 self, removal: &'life1 RuntimeRemoval, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeUnitRecord>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Source

fn complete_exec<'life0, 'life1, 'async_trait>( &'life0 self, result: &'life1 RuntimeExecResult, ) -> Pin<Box<dyn Future<Output = RuntimeResult<RuntimeUnitRecord>> + Send + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Dyn Compatibility§

This trait is dyn compatible.

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

Implementors§