Struct Worker 

pub struct Worker { /* private fields */ }

Implementations

impl Worker

pub fn from_settings() -> Result<Worker>

Create a new Worker instance from RuntimeConfig settings which is sourced from the environment

pub fn from_config(config: RuntimeConfig) -> Result<Worker>

Create a new Worker instance from a provided RuntimeConfig

pub fn runtime_from_existing() -> Result<Runtime>

Share the process-wide runtime, creating it on first use.

The returned Runtime only wraps a handle to RT, so every caller ends up on the same Tokio runtime. Creation goes through Worker::ensure_process_runtime rather than happening here, so the runtime stays reachable as a &'static for the pyo3 bridge.

pub fn ensure_process_runtime() -> Result<&'static Runtime>

Create the process-wide runtime if it does not exist yet, and return it. Idempotent.

Exists because the pyo3 bridge needs a &'static tokio::runtime::Runtime, which Worker::from_config cannot provide — it errors when a runtime already exists.

pub fn has_existing_runtime() -> bool

Whether the process-wide runtime already exists.

Never creates one, unlike Worker::runtime_from_existing, so a caller can use this to find out whether it would be the owner.

pub fn tokio_runtime(&self) -> Result<&'static Runtime>

pub fn runtime(&self) -> &Runtime

pub fn execute<F, Fut>(self, f: F) -> Result<()>

where F: FnOnce(Runtime) -> Fut + Send + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub async fn execute_async<F, Fut>(self, f: F) -> Result<()>

where F: FnOnce(Runtime) -> Fut + Send + 'static, Fut: Future<Output = Result<()>> + Send + 'static,

pub fn from_current() -> Result<Worker>

Trait Implementations

impl Clone for Worker

fn clone(&self) -> Worker

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Worker

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.