Skip to main content

spawn_worker_with_sink

Function spawn_worker_with_sink 

Source
pub fn spawn_worker_with_sink(
    capacity: usize,
    bridge: Arc<dyn EventBus>,
    embedder: Arc<dyn Embedder>,
    vector_sink: Arc<dyn VectorSink>,
    metrics: Arc<Registry>,
) -> WorkerHandle
Expand description

Start the worker pool with an explicit off-path vector sink.