Module worker

Structs§

ConnectorSourceWorker: ConnectorSourceWorker keeps fetching the latest split metadata from the external source service (Self::tick), and maintains it in current_splits.
ConnectorSourceWorkerHandle: Handle for a running ConnectorSourceWorker.
SharedSplitMap

DEBUG_SPLITS_KEY 🔒
DEFAULT_SOURCE_WORKER_TICK_INTERVAL 🔒
MAX_FAIL_CNT 🔒
TICK_INFLIGHT_WARN_INTERVAL 🔒: Interval at which a still-running (in-flight) source worker tick emits a progressive warning.

create_source_worker: Used to create a new ConnectorSourceWorkerHandle for a new source.
create_source_worker_async: Used on startup (SourceManager::new). Failed sources will not block meta startup.
extract_prop_from_existing_source 🔒
extract_prop_from_new_source 🔒
run_tick_with_progressive_warn 🔒: Drive a source worker tick future to completion, recording its duration in tick_duration and emitting a warn! every TICK_INFLIGHT_WARN_INTERVAL while it is still pending. The future is never cancelled or timed out, so tick() semantics are unchanged.