Struct EventManager 

pub struct EventManager {
    pub event_callback: Option<Arc<Mutex<Box<dyn EventCallback + Send + Sync>>>>,
    pub event_flags: EventType,
    pub dry_run: bool,
    pub pipeline_stats: Arc<Mutex<PipelineStats>>,
}

Manages event callback registration and dispatching.

Holds an optional EventCallback trait object and accumulated pipeline statistics. On PIPELINE_END, sends a STATS_REPORT event with accumulated stats if the caller subscribed to STATS_REPORT via event_flags.

Fields

event_callback: Option<Arc<Mutex<Box<dyn EventCallback + Send + Sync>>>>

event_flags: EventType

dry_run: bool

pipeline_stats: Arc<Mutex<PipelineStats>>

Implementations

impl EventManager

pub fn new() -> Self

pub fn register_callback<T: EventCallback + Send + Sync + 'static>( &mut self, events_flag: EventType, callback: T, dry_run: bool, )

Register an event callback with event type filter and dry-run flag.

pub fn is_callback_registered(&self) -> bool

Returns true if an event callback has been registered.

pub async fn trigger_event(&self, event_data: EventData)

Trigger an event, updating internal stats and dispatching to the callback.

Trait Implementations

impl Clone for EventManager

fn clone(&self) -> EventManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for EventManager

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

Formats the value using the given formatter.

impl Default for EventManager

fn default() -> Self

Returns the “default value” for a type.