Trait WriteRequestConsumer 

pub trait WriteRequestConsumer:
    Send
    + Sync
    + Debug {
    // Required method
    fn consume(&self, request: &WriteRequestNominal) -> ConsumerResult<()>;
}

Required Methods

fn consume(&self, request: &WriteRequestNominal) -> ConsumerResult<()>

Implementors

impl WriteRequestConsumer for AvroFileConsumer

impl<C> WriteRequestConsumer for ListeningWriteRequestConsumer<C>

where C: WriteRequestConsumer + Send + Sync,

impl<P, F> WriteRequestConsumer for RequestConsumerWithFallback<P, F>

where P: WriteRequestConsumer + Send + Sync, F: WriteRequestConsumer + Send + Sync,

impl<P, S> WriteRequestConsumer for DualWriteRequestConsumer<P, S>

where P: WriteRequestConsumer + Send + Sync, S: WriteRequestConsumer + Send + Sync,

impl<T: AuthProvider + 'static> WriteRequestConsumer for NominalCoreConsumer<T>