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