Struct EventLogger 

pub struct EventLogger { /* private fields */ }

Event logger for MapReduce jobs

Implementations

impl EventLogger

pub fn new(writers: Vec<Box<dyn EventWriter>>) -> Self

Create a new event logger

pub fn with_config( writers: Vec<Box<dyn EventWriter>>, flush_interval: Duration, buffer_size_limit: usize, ) -> Self

Create a new event logger with custom configuration

pub async fn log(&self, event: MapReduceEvent) -> Result<()>

Log an event

pub async fn log_with_metadata( &self, event: MapReduceEvent, metadata: HashMap<String, Value>, ) -> Result<()>

Log an event with custom metadata

pub async fn set_correlation_id(&self, id: String)

Set the current correlation ID

pub async fn current_correlation_id(&self) -> String

Get the current correlation ID

pub async fn flush(&self) -> Result<()>

Flush buffered events to all writers

pub async fn log_dlq_event_with_job( &self, job_id: String, event: DLQEvent, ) -> Result<()>

Log a DLQ event with the appropriate job ID

pub fn start_background_flush(self: Arc<Self>) -> JoinHandle<()>

Start background flush task

pub async fn shutdown(&self) -> Result<()>

Shutdown the logger

pub fn stats(&self) -> EventStats

Get event statistics