Trait ChangeEventSink 

pub trait ChangeEventSink: Send + Sync {
    // Required method
    fn record_change_event(&self, event: &ChangeEvent);
}

Trait alias for any sink that can receive ChangeEvent records.

The trait is sealed by the record_change_event free function — callers do not need to implement it themselves. It exists so callers that want a custom sink (e.g. an S3 uploader or a Prometheus histogram bridge) can plug in.

Required Methods

fn record_change_event(&self, event: &ChangeEvent)

Record a single ChangeEvent.

Implementors

impl ChangeEventSink for MetricsCollector

Available on crate feature metrics only.

impl ChangeEventSink for InMemoryChangeFeedSink