Struct PostgresCdcBuilder 

pub struct PostgresCdcBuilder { /* private fields */ }

Builder for a PostgreSQL pgoutput source.

Implementations

impl PostgresCdcBuilder

pub fn connect(self, config: PostgresCdcConfig) -> Self

pub fn connect_url(self, url: impl AsRef<str>) -> CdcResult<Self>

pub fn slot(self, slot: impl Into<String>) -> Self

pub fn publication(self, publication: impl Into<String>) -> Self

pub fn start_from(self, start: CdcStart) -> Self

pub fn feedback(self, feedback: FeedbackMode) -> Self

pub fn slot_lifecycle(self, lifecycle: SlotLifecycle) -> Self

pub fn buffer_capacity(self, capacity: usize) -> Self

pub fn replication_buffer_events(self, capacity: usize) -> Self

pub fn status_interval(self, interval: Duration) -> Self

pub fn idle_wakeup_interval(self, interval: Duration) -> Self

pub fn validate_publication(self, enabled: bool) -> Self

pub fn checkpoint_store<S>(self, store: S) -> Self

where S: CdcCheckpointStore,

pub fn checkpoint_store_arc(self, store: Arc<dyn CdcCheckpointStore>) -> Self

pub fn reconnect(self, settings: ReconnectSettings) -> Self

pub fn disable_reconnect(self) -> Self

pub fn build(self) -> CdcResult<Source<ChangeEvent, CdcHandle>>

pub fn build_with_context( self, ) -> CdcResult<SourceWithContext<ChangeEvent, CdcOffset, CdcHandle>>

pub fn restart_factory( self, ) -> CdcResult<impl Fn() -> Source<ChangeEvent, CdcHandle> + Clone + Send + Sync + 'static>

Trait Implementations

impl Clone for PostgresCdcBuilder

fn clone(&self) -> PostgresCdcBuilder

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for PostgresCdcBuilder

fn default() -> Self

Returns the “default value” for a type.