Struct CloudEventsGrpcHandler 

pub struct CloudEventsGrpcHandler { /* private fields */ }

gRPC CloudEvents projector service implementation.

Wraps a CloudEventsRouter to transform events into CloudEvents. Uses the standard ProjectorService protocol but returns CloudEventsResponse packed into Projection.projection.

Implementations

impl CloudEventsGrpcHandler

pub fn new(router: CloudEventsRouter) -> Self

Create a new CloudEvents handler from a router.

pub fn router(&self) -> &CloudEventsRouter

Get the underlying router.

Trait Implementations

impl ProjectorService for CloudEventsGrpcHandler

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

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

Async projection - projector should persist and return

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

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

Speculative processing - projector must avoid external side effects