pub struct AsyncEventsBlockProcessor { /* private fields */ }Expand description
A BlockProcessor implementation for processing async event blocks.
Implementations§
Source§impl AsyncEventsBlockProcessor
impl AsyncEventsBlockProcessor
pub fn new(convert_ticks: Arc<ConvertTicks>) -> AsyncEventsBlockProcessor
Trait Implementations§
Source§impl BlockProcessor for AsyncEventsBlockProcessor
impl BlockProcessor for AsyncEventsBlockProcessor
Source§fn process<'life0, 'async_trait>(
&'life0 self,
blob_storage: Arc<BlobStorage>,
src_block: Arc<PartitionSourceBlock>,
) -> Pin<Box<dyn Future<Output = Result<Option<PartitionRowSet>, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
AsyncEventsBlockProcessor: 'async_trait,
fn process<'life0, 'async_trait>(
&'life0 self,
blob_storage: Arc<BlobStorage>,
src_block: Arc<PartitionSourceBlock>,
) -> Pin<Box<dyn Future<Output = Result<Option<PartitionRowSet>, Error>> + Send + 'async_trait>>where
'life0: 'async_trait,
AsyncEventsBlockProcessor: 'async_trait,
Processes a single block of telemetry.
Auto Trait Implementations§
impl Freeze for AsyncEventsBlockProcessor
impl RefUnwindSafe for AsyncEventsBlockProcessor
impl Send for AsyncEventsBlockProcessor
impl Sync for AsyncEventsBlockProcessor
impl Unpin for AsyncEventsBlockProcessor
impl UnwindSafe for AsyncEventsBlockProcessor
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request§impl<L> LayerExt<L> for L
impl<L> LayerExt<L> for L
§fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
fn named_layer<S>(&self, service: S) -> Layered<<L as Layer<S>>::Service, S>where
L: Layer<S>,
Applies the layer to a service and wraps it in [
Layered].