Struct ProcessManagerGrpcHandler 

pub struct ProcessManagerGrpcHandler<S: Default + Send + Sync + 'static> { /* private fields */ }

gRPC process manager service implementation.

Wraps a ProcessManagerRouter to handle PM events.

Implementations

impl<S: Default + Send + Sync + 'static> ProcessManagerGrpcHandler<S>

pub fn new(router: ProcessManagerRouter<S>) -> Self

Create a new process manager handler from a router.

pub fn router(&self) -> &ProcessManagerRouter<S>

Get the underlying router.

Trait Implementations

impl<S: Default + Send + Sync + 'static> ProcessManagerService for ProcessManagerGrpcHandler<S>

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

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

Phase 1: Declare which additional destinations are needed beyond the trigger. PM automatically receives triggering event’s domain state.

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

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

Phase 2: Handle with trigger + process state + fetched destinations. Returns commands for other aggregates and events for the PM’s own domain.