Struct TpcRuntime 

pub struct TpcRuntime { /* private fields */ }

Thread-per-core runtime managing N CoreHandles and their source I/O threads.

Implementations

impl TpcRuntime

pub fn new(config: &TpcConfig) -> Result<Self, TpcError>

Create a new TPC runtime with the given configuration.

Spawns config.num_cores core threads immediately.

Errors

Returns an error if the configuration is invalid or core threads fail to spawn.

pub fn attach_source( &mut self, source_idx: usize, name: String, connector: Box<dyn SourceConnector>, connector_config: ConnectorConfig, pipeline_config: &PipelineConfig, restore_checkpoint: Option<SourceCheckpoint>, ) -> Result<()>

Attach a source to a core, spawning an I/O thread.

Sources are assigned to cores in round-robin order.

Panics

Panics if a core already has a source attached (SPSC invariant). Ensure num_cores >= num_sources.

Errors

Returns std::io::Error if the source I/O thread cannot be spawned.

pub fn poll_all_outputs(&self, buffer: &mut Vec<TaggedOutput>) -> usize

Drain all core outboxes into the buffer. Returns total outputs collected.

pub fn injector(&self, source_idx: usize) -> &CheckpointBarrierInjector

Get the barrier injector for a source (used by coordinator for checkpoint).

pub fn source_checkpoint(&self, source_idx: usize) -> SourceCheckpoint

Get checkpoint snapshot for a source (lock-free watch read).

pub fn snapshot_all_source_checkpoints( &self, ) -> FxHashMap<String, SourceCheckpoint>

Snapshot all source checkpoints (lock-free watch reads).

Returns a map of source name → current checkpoint. Used by timer-based checkpoints to capture source offsets without barriers.

pub fn failed_sources(&self) -> Vec<String>

Returns names of sources whose I/O threads exited without starting (open or restore failed). Empty means all sources are healthy or still initializing.

pub fn source_metrics(&self, source_idx: usize) -> &Arc<SourceIoMetrics>

Get metrics for a source.

pub fn shutdown(&mut self) -> Vec<(String, Box<dyn SourceConnector>)>

Shutdown all I/O threads and core handles. Returns connectors for close().

pub fn num_cores(&self) -> usize

Returns the number of cores.

pub fn source_names(&self) -> &[String]

Returns the source names.

pub fn num_sources(&self) -> usize

Returns the number of attached sources.

pub fn drain_all_io_completions(&self, out: &mut Vec<IoCompletion>)

Drain storage I/O completions from all cores into out.

Called by the checkpoint coordinator (Ring 2) before checking WAL sync status. Collects completions that Ring 0 pushed after polling its StorageIo backend.

pub fn output_signal(&self) -> (Arc<AtomicBool>, Arc<Notify>)

Returns the shared output signaling handles.

The coordinator awaits notified() on the Notify and clears the AtomicBool after each drain cycle.

Trait Implementations

impl Debug for TpcRuntime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.