Struct akka_projection_rs_grpc::consumer::GrpcSourceProvider

pub struct GrpcSourceProvider<E, EP> { /* private fields */ }

Provides a source of gRPC events consumed from a remote producer.

Implementations

impl<E, EP, EPR> GrpcSourceProvider<E, EP>where EP: Fn() -> EPR, EPR: Future<Output = Result<Channel, Error>>,

pub fn new(event_producer_channel: EP, stream_id: StreamId) -> Self

Construct a new source with a closure that is able to construct connections in any way that is required e.g. a secure connection using TLS, or using UDP etc.

pub fn with_slice_range( event_producer_channel: EP, stream_id: StreamId, slice_range: Range<u32> ) -> Self

If more than one slice range is required then it can be conveyed here.

pub fn with_initial_consumer_filters( self, consumer_filters: Vec<FilterCriteria> ) -> Self

Provide an initial filter, or any empty Vec if none are required. If more filters are required to be sent then Self::consumer_filters can be used to obtain the means to do so.

pub fn consumer_filters(&mut self) -> Option<Sender<Vec<FilterCriteria>>>

Obtain the means to send filters dynamically. There can be only one sender, so calls subsequent to the first one will result in None being returned. Additionally, None is returned if no initial filters are declared.

Trait Implementations

impl<E, EP, EPR> SourceProvider for GrpcSourceProvider<E, EP>where E: Default + Message + Send + Sync, EP: Fn() -> EPR + Send + Sync, EPR: Future<Output = Result<Channel, Error>> + Send,

type Envelope = Envelope<E>

The envelope processed by the provider.

fn source<'life0, 'async_trait, F, FR>( &'life0 self, offset: F ) -> Pin<Box<dyn Future<Output = Pin<Box<dyn Stream<Item = Self::Envelope> + Send + 'async_trait>>> + Send + 'async_trait>>where F: Fn() -> FR + Send + Sync + 'async_trait, FR: Future<Output = Option<LastOffset>> + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait,

Given a closure that returns an offset, source envelopes.

fn load_envelope<'life0, 'async_trait>( &'life0 self, persistence_id: PersistenceId, seq_nr: u64 ) -> Pin<Box<dyn Future<Output = Option<Self::Envelope>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Load a single event on demand. A None is returned if the event for the given persistence_id and seq_nr doesn’t exist.