Struct mediasoup::worker_manager::WorkerManager

pub struct WorkerManager { /* fields omitted */ }

Container that creates Worker instances.

Examples

use futures_lite::future;
use mediasoup::worker::WorkerSettings;
use mediasoup::worker_manager::WorkerManager;

// Create a manager that will use specified binary for spawning new worker processes
let worker_manager = WorkerManager::new(
    "/path/to/mediasoup-worker".into(),
);

future::block_on(async move {
    // Create a new worker with default settings
    let worker = worker_manager
        .create_worker(WorkerSettings::default())
        .await
        .unwrap();
})

If you already happen to have async_executor::Executor instance available or need a multi-threaded executor, WorkerManager::with_executor() can be used to create an instance instead.

Implementations

impl WorkerManager

pub fn new(worker_binary: PathBuf) -> Self

Create new worker manager, internally a new single-threaded executor will be created.

pub fn with_executor(
    worker_binary: PathBuf,
    executor: Arc<Executor<'static>>
) -> Self

Create new worker manager, uses externally provided executor.

pub async fn create_worker(
    &self,
    worker_settings: WorkerSettings
) -> Result<Worker>

Creates a new worker with the given settings.

Worker manager will be kept alive as long as at least one worker instance is alive.

pub fn on_new_worker<F: Fn(&Worker) + Send + Sync + 'static>(
    &self,
    callback: F
) -> HandlerId

Callback is called when a new worker is created.

Trait Implementations

impl Clone for WorkerManager

pub fn clone(&self) -> WorkerManager

Returns a copy of the value.

pub fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.