Struct CdcApp 

pub struct CdcApp { /* private fields */ }

High-level CDC application runner

This struct encapsulates the complete CDC application workflow, providing a clean interface for running CDC replication with proper initialization, shutdown handling, and error management.

Implementations

impl CdcApp

pub async fn new(config: CdcAppConfig) -> CdcResult<Self>

Create a new CDC application instance

Arguments

• config - The CDC application configuration to use

Returns

Returns a CdcResult<CdcApp> with the initialized application instance.

Errors

Returns CdcError if the CDC client cannot be created or initialized.

pub async fn from_config(cdc_config: Config) -> CdcResult<Self>

Create a new CDC application instance with just the CDC config (backwards compatible)

Arguments

• cdc_config - The CDC configuration to use

Returns

Returns a CdcResult<CdcApp> with the initialized application instance.

Errors

Returns CdcError if the CDC client cannot be created or initialized.

pub async fn run(&mut self, lsn_file_path: Option<&str>) -> CdcResult<()>

Run the CDC application with graceful shutdown handling

This method starts the CDC replication process and handles graceful shutdown when shutdown signals are received. It automatically loads the last LSN from persistence to resume replication from where it left off.

This method now automatically handles metrics server initialization when the metrics feature is enabled, removing the need for feature checking in the main application.

Arguments

• lsn_file_path - Optional path to the LSN persistence file. If None, uses the default from environment variables or “./pg2any_last_lsn”

Returns

Returns CdcResult<()> when the application completes successfully or is gracefully shut down.

Errors

Returns CdcError if:

• Replication fails to start or encounters an error
• Shutdown handling fails
• Client stop operation fails
• Metrics server fails to start (when metrics feature is enabled)