Module source_adapter 

Source I/O thread adapter for thread-per-core mode.

Bridges an async SourceConnector to a core thread’s SPSC inbox. Each source runs on a dedicated std::thread with a single-threaded tokio runtime, pushing CoreMessage::Event into the target core’s inbox after converting SourceBatch → Event.

Structs

SourceIoMetrics

Per-source metrics (lock-free atomic reads from any thread).

SourceIoThread

Bridges an async SourceConnector to a core thread’s SPSC inbox.