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

Enums

SourceWorkerCommand

Constants

DEBUG_SPLITS_KEY 🔒

DEFAULT_SOURCE_TICK_TIMEOUT 🔒

DEFAULT_SOURCE_WORKER_TICK_INTERVAL 🔒

MAX_FAIL_CNT 🔒

Functions

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 🔒

Type Aliases

SharedSplitMapRef 🔒