vil_trigger_cdc 0.1.1

VIL Phase 3 — Database Change Data Capture trigger via PostgreSQL logical replication
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

// =============================================================================
// vil_trigger_cdc::process — create_trigger helper
// =============================================================================
//
// Convenience constructor for wrapping a CdcTrigger ready for use as a VIL
// ServiceProcess component.
// =============================================================================

use std::sync::Arc;

use vil_trigger_core::traits::TriggerSource;

use crate::config::CdcConfig;
use crate::source::CdcTrigger;

/// Create a `CdcTrigger` wrapped in an `Arc<dyn TriggerSource>`.
///
/// # Usage
/// ```ignore
/// use vil_trigger_cdc::process::create_trigger;
/// let trigger = create_trigger(CdcConfig::new("host=...", "slot", "pub"));
/// ```
pub fn create_trigger(config: CdcConfig) -> Arc<dyn TriggerSource> {
    Arc::new(CdcTrigger::new(config))
}