vil_trigger_cdc 0.2.0

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

// =============================================================================
// vil_trigger_cdc::state — connector state for ServiceProcess health metrics
// =============================================================================

use vil_connector_macros::connector_state;

/// Live state metrics for the CDC trigger.
#[connector_state]
pub struct CdcTriggerState {
    /// Total row change events emitted.
    pub rows_changed: u64,
    /// Total keepalive messages sent to the server.
    pub keepalives_sent: u64,
    /// Total replication stream errors encountered.
    pub stream_errors: u64,
    /// Timestamp (ns) of the most recent row change event (0 if none).
    pub last_event_ns: u64,
}