risingwave_meta::stream::source_manager

Function create_source_worker_handle

source
pub async fn create_source_worker_handle(
    source: &Source,
    metrics: Arc<MetaMetrics>,
) -> MetaResult<ConnectorSourceWorkerHandle>
Expand description

Used to create a new ConnectorSourceWorkerHandle for a new source.

It will call ConnectorSourceWorker::tick() to fetch split metadata once before returning.