Struct Runtime 

pub struct Runtime { /* private fields */ }

Implementations

impl Runtime

pub async fn new( message_store: MessageStore, relay: Relay, modules_path: impl Into<PathBuf>, ) -> Result<Self>

pub fn message_store(&self) -> &MessageStore

pub async fn execute( &self, name: Category<'static>, id: ID<'static>, command: String, payload: Value, ) -> Result<Vec<GenericMessage<'static>>>

pub async fn save_module( &self, name: Category<'static>, module: impl AsRef<[u8]>, ) -> Result<()>

pub async fn start_projection( &self, tx: Sender<GenericMessage<'static>>, name: String, events: Vec<String>, ) -> Result<()>

pub fn subscribe_events(&self) -> Receiver<GenericMessage<'static>>

pub async fn acknowledge_event( &self, name: impl Into<String>, global_id: u64, ) -> Result<()>

Trait Implementations

impl Clone for Runtime

fn clone(&self) -> Runtime

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl CommandCenter for Runtime

fn execute<'life0, 'async_trait>( &'life0 self, request: Request<ExecuteCommand>, ) -> Pin<Box<dyn Future<Output = Result<Response<ExecuteResponse>, Status>> + Send + 'async_trait>>

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

fn publish<'life0, 'async_trait>( &'life0 self, request: Request<PublishModule>, ) -> Pin<Box<dyn Future<Output = Result<Response<PublishResponse>, Status>> + Send + 'async_trait>>

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

impl Projection for Runtime

type SubscribeToEventsStream = Pin<Box<dyn Stream<Item = Result<Message, Status>> + Send>>

Server streaming response type for the SubscribeToEvents method.

fn subscribe_to_events<'life0, 'async_trait>( &'life0 self, request: Request<SubscriptionRequest>, ) -> Pin<Box<dyn Future<Output = Result<Response<Self::SubscribeToEventsStream>, Status>> + Send + 'async_trait>>

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

fn acknowledge_event<'life0, 'async_trait>( &'life0 self, request: Request<Acknowledgement>, ) -> Pin<Box<dyn Future<Output = Result<Response<AckResponse>, Status>> + Send + 'async_trait>>

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