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 🔒