Struct CompositeObserver 

pub struct CompositeObserver { /* private fields */ }

An observer that fans out callbacks to a list of observers.

Implementations

impl CompositeObserver

pub fn new(observers: Vec<Arc<dyn IngestionObserver>>) -> Self

Create a new composite observer from a list of observers.

Trait Implementations

impl Debug for CompositeObserver

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

Formats the value using the given formatter.

impl Default for CompositeObserver

fn default() -> CompositeObserver

Returns the “default value” for a type.

impl IngestionObserver for CompositeObserver

fn on_success(&self, ctx: &IngestionContext, stats: IngestionStats)

Called when ingestion succeeds.

fn on_failure( &self, ctx: &IngestionContext, severity: IngestionSeverity, error: &IngestionError, )

Called when ingestion fails.

fn on_alert( &self, ctx: &IngestionContext, severity: IngestionSeverity, error: &IngestionError, )

Called when an ingestion failure meets an alert threshold.