Module callback 

Pipeline callback trait and source registration types.

Decouples the pipeline coordinator from db.rs internals so the TPC coordinator can drive SQL cycles, sink writes, and checkpoints through a narrow interface.

Structs

CycleOutcome

Result of a pipeline cycle. Per-domain failure isolation lets healthy failure domains commit and advance while a faulted domain’s sources are held back for replay.

SourceRegistration

A registered source with its name and config.

Enums

BarrierOutcome

Outcome of a barrier-aligned checkpoint attempt.

CycleError

How a failed execute_cycle should be handled by the coordinator.

SkipReason

Why a barrier checkpoint was deliberately skipped, as opposed to attempted-and-failed.

Traits

PipelineCallback

Callback trait for the coordinator to interact with the rest of the DB. Trait exists for test seam; production impl is ConnectorPipelineCallback.