Struct Runtime 

pub struct Runtime<A: Application> {
    pub state: StateManager<A>,
    pub records: RecordManager<A>,
    pub streams: StreamManager<A>,
    pub operations: OperationManager,
    pub evidence: Evidence<A>,
    /* private fields */
}

Fields

state: StateManager<A>

records: RecordManager<A>

streams: StreamManager<A>

operations: OperationManager

evidence: Evidence<A>

Implementations

impl<A: Application> Runtime<A>

pub async fn start_storage<C>(&self, storage: StorageManager<C>) -> Result<()>

pub fn storage(&self) -> Option<&StorageManager<ErasedCatalog>>

pub async fn stop_with_timeout(&self, timeout: Duration) -> Result<Position>

pub async fn stop(&self) -> Result<Position>

impl<A: Application> Runtime<A>

pub fn builder( origin: impl Into<Origin<A::State>>, resources: impl Into<Arc<A::Resources>>, ) -> Builder<A>

pub async fn inspect( origin: impl Into<Origin<A::State>>, source: impl Source<A>, ) -> Result<Inspector<A>, Incompatible>

pub fn stop_participant(&self) -> StopParticipant

pub fn notices(&self) -> Receiver<Option<String>>

pub fn handle(&self) -> Handle<A>