Struct akka_projection_rs_grpc::proto::event_producer_service_server::EventProducerServiceServer

pub struct EventProducerServiceServer<T: EventProducerService> { /* private fields */ }

EventProducerService runs on the producer side and implements the producer side of the EventsBySlices query, which can be used with Akka Projection over gRPC.

1. Events are stored in the event journal on the producer side.
2. Consumer side starts an Akka Projection which locally reads its offset from the Projection offset store.
3. Consumer side establishes a replication stream from the producer service by sending the InitReq with the offset to start from.
4. Events are read from the journal on the producer side and emitted to the replication stream.
5. Consumer side processes the events in a Projection handler.
6. Offset is stored on the consumer side by the Projection offset store.
7. Producer continues to read new events from the journal and emit to the stream.

The consumer can define event filters with the FilterCriteria, which can be included in the InitReq and also changed in runtime by sending FilterReq.

Implementations

impl<T: EventProducerService> EventProducerServiceServer<T>

pub fn new(inner: T) -> Self

pub fn from_arc(inner: Arc<T>) -> Self

pub fn with_interceptor<F>( inner: T, interceptor: F ) -> InterceptedService<Self, F>where F: Interceptor,

pub fn accept_compressed(self, encoding: CompressionEncoding) -> Self

Enable decompressing requests with the given encoding.

pub fn send_compressed(self, encoding: CompressionEncoding) -> Self

Compress responses with the given encoding, if the client supports it.

pub fn max_decoding_message_size(self, limit: usize) -> Self

Limits the maximum size of a decoded message.

Default: 4MB

pub fn max_encoding_message_size(self, limit: usize) -> Self

Limits the maximum size of an encoded message.

Default: usize::MAX

Trait Implementations

impl<T: EventProducerService> Clone for EventProducerServiceServer<T>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<T: Debug + EventProducerService> Debug for EventProducerServiceServer<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: EventProducerService> NamedService for EventProducerServiceServer<T>

const NAME: &'static str = "akka.projection.grpc.EventProducerService"

The Service-Name as described here.

impl<T, B> Service<Request<B>> for EventProducerServiceServer<T>where T: EventProducerService, B: Body + Send + 'static, B::Error: Into<StdError> + Send + 'static,

type Response = Response<UnsyncBoxBody<Bytes, Status>>

Responses given by the service.

type Error = Infallible

Errors produced by the service.

type Future = Pin<Box<dyn Future<Output = Result<<EventProducerServiceServer<T> as Service<Request<B>>>::Response, <EventProducerServiceServer<T> as Service<Request<B>>>::Error>> + Send>>

The future response value.

fn poll_ready(&mut self, _cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>>

Returns Poll::Ready(Ok(())) when the service is able to process requests.

fn call(&mut self, req: Request<B>) -> Self::Future

Process the request and return the response asynchronously.