Trait CdcOutputProvider 

pub trait CdcOutputProvider: Send + Sync {
    // Required methods
    fn name(&self) -> &str;
    fn start(
        &self,
        ctx: CdcStartContext<'_>,
    ) -> Result<Box<dyn CdcStream>, FnError>;
}

A CDC-output provider — produces an Arc<dyn CdcStream> on start.

Required Methods

fn name(&self) -> &str

Provider name ("kafka", "pulsar", "jsonl", …).

fn start(&self, ctx: CdcStartContext<'_>) -> Result<Box<dyn CdcStream>, FnError>

Start a new CDC stream.

Errors

Returns FnError if the sink cannot be initialized.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors