Struct ProcessingModule

Source

pub struct ProcessingModule<Processor> { /* private fields */ }

Expand description

Represents collector of records. This module is responsible for receiving events and saving them using various means. Processing module is only responsible for managing the lifecycle, and doesn’t handele any data saving itself. Data saving is done through EventProcessor.

ProcessingModule

Struct ProcessingModule Copy item path

Implementations§

impl<P: EventProcessor> ProcessingModule<P>

pub fn new(receiver: Receiver<RecordEvent>, processor: P) -> Self

pub async fn run(self) -> Result<()>

Auto Trait Implementations§

impl<Processor> Freeze for ProcessingModule<Processor>where Processor: Freeze,

impl<Processor> RefUnwindSafe for ProcessingModule<Processor>where Processor: RefUnwindSafe,

impl<Processor> Send for ProcessingModule<Processor>where Processor: Send,

impl<Processor> Sync for ProcessingModule<Processor>where Processor: Sync,

impl<Processor> Unpin for ProcessingModule<Processor>where Processor: Unpin,

impl<Processor> UnwindSafe for ProcessingModule<Processor>where Processor: UnwindSafe,

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> IntoEither for T

fn into_either(self, into_left: bool) -> Either<Self, Self>

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>where F: FnOnce(&Self) -> bool,

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>

Struct ProcessingModule

impl<Processor> Freeze for ProcessingModule<Processor>
where Processor: Freeze,

impl<Processor> RefUnwindSafe for ProcessingModule<Processor>
where Processor: RefUnwindSafe,

impl<Processor> Send for ProcessingModule<Processor>
where Processor: Send,

impl<Processor> Sync for ProcessingModule<Processor>
where Processor: Sync,

impl<Processor> Unpin for ProcessingModule<Processor>
where Processor: Unpin,

impl<Processor> UnwindSafe for ProcessingModule<Processor>
where Processor: UnwindSafe,

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T, U> Into<U> for T
where U: From<T>,

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>
where S: Into<Dispatch>,