Skip to main content

run_apply_loop

pgsync_core::engine

Function run_apply_loop 

Source 
pub async fn run_apply_loop<S, K>(
    stream: S,
    sink: K,
    cp: Checkpoint,
    catchup_target: Lsn,
    resources: &ResourcesConfig,
    metrics: Arc<Metrics>,
    cancel: CancellationToken,
    progress: ProgressHandle,
) -> Result<ApplyOutcome>
where
    S: EventStream + 'static,
    K: ReplicationSink,
Expand description

Runs one connected stream until cancellation or error.

catchup_target is the server WAL end observed when the stream was opened; once the acknowledged position reaches it the job state becomes STREAMING.