Modules§
Structs§
- SourceManager 
- SourceManagerkeeps 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).
- SourceManager Core 
- SourceManager Running Info 
- SplitDiff Options 
- SplitState 
Enums§
Constants§
Functions§
- build_actor_ connector_ splits 
- build_actor_ split_ impls 
- create_source_ worker 
- Used to create a new ConnectorSourceWorkerHandlefor a new source.
- reassign_splits 
- Reassigns splits if there are new splits or dropped splits,
i.e., actor_splitsanddiscovered_splitsdiffer, or actors are rescheduled.