Trait NotificationDataSource 

pub trait NotificationDataSource: Send + Sync {
    // Required method
    fn resolve(&self, notif: &NotificationRef) -> Option<ChangeEvent>;
}

Resolves a NotificationRef into a full ChangeEvent.

Implemented by the DAG executor or streaming pipeline to provide zero-copy access to the source data referenced by NotificationRef::batch_offset.

Required Methods

fn resolve(&self, notif: &NotificationRef) -> Option<ChangeEvent>

Resolves a notification reference to a full change event.

Returns None if the referenced data is no longer available (e.g., the ring buffer has been overwritten). The dispatcher will skip the notification and increment the drop counter.

Implementors