Function dispatch_event

nodedb/src/event/consumer_helpers.rs:140–152

Dispatch a single write event: triggers, CDC, permission cache, streaming MVs, CRDT sync. Called for both Normal-mode ring-buffer events and WAL-catchup-replayed events.

(
    event: &WriteEvent,
    shared_state: &Arc<SharedState>,
    retry_queue: &mut TriggerRetryQueue,
    cdc_router: &Arc<super::cdc::CdcRouter>,
)

///
/// Called for both Normal-mode ring-buffer events and WAL-catchup-replayed events.
pub async fn dispatch_event(
    event: &WriteEvent,
    shared_state: &Arc<SharedState>,
    retry_queue: &mut TriggerRetryQueue,
    cdc_router: &Arc<super::cdc::CdcRouter>,
) {
    shared_state
        .watermark_tracker
        .advance_lsn_only(event.vshard_id.as_u32(), event.lsn.as_u64());

    super::trigger::dispatcher::dispatch_triggers(event, shared_state, retry_queue).await;
    cdc_router.route_event(event, &shared_state.watermark_tracker);
}

/// Dispatch a data write event (op.is_data_event() == true): advances wall-time watermark,
/// batches triggers, routes CDC, updates permission cache, feeds streaming MVs and CRDT sync.