Module source_manager

Re-exports

• pub use worker::create_source_worker;

Modules

• split_assignment 🔒
• worker 🔒

Structs

• SourceManager
  SourceManager keeps fetching the latest split metadata from the external source services (worker::ConnectorSourceWorker::tick), and sends a split assignment command if split changes detected (Self::tick).
• SourceManagerCore
• SourceManagerRunningInfo

Enums

• SourceChange

Functions

• build_actor_connector_splits
• build_actor_split_impls

Type Aliases

• SourceManagerRef
• SplitAssignment
• ThrottleConfig