Struct CdcTrigger 

pub struct CdcTrigger { /* private fields */ }

VIL CDC trigger — connects to PostgreSQL logical replication and fires a TriggerEvent on every DML change in the watched publication.

Implementations

impl CdcTrigger

pub fn new(config: CdcConfig) -> Self

Create a new CdcTrigger from config.

Trait Implementations

impl TriggerSource for CdcTrigger

fn kind(&self) -> &'static str

Unique, stable identifier for this trigger kind (e.g. "cdc", "email").

fn start<'life0, 'async_trait>( &'life0 self, on_event: EventCallback, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Start watching for events.

fn pause<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Pause the trigger without destroying source state.

fn resume<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Resume after a previous pause.

fn stop<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), TriggerFault>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gracefully stop the trigger and release all resources.