Skip to main content

Module callback

Module callback 

Source
Expand description

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§

SourceRegistration
A registered source with its name and config.

Traits§

PipelineCallback
Callback trait for the coordinator to interact with the rest of the DB.