Struct RuntimeSpawner

Source

pub struct RuntimeSpawner { /* private fields */ }

Expand description

A Send + Sync, freely cloneable capability to spawn processes into a Runtime, detached from the Runtime value itself. Exists because super::supervisor::Supervisor needs to respawn processes from a background monitor thread whose lifetime isn’t tied to the Runtime object’s own (which owns non-Sync JoinHandles for its workers).

RuntimeSpawner

Struct RuntimeSpawner Copy item path

Implementations§

impl RuntimeSpawner

pub fn spawn( &self, function: u32, args: &[Value], restart_policy: RestartPolicy, ) -> Result<FlowHandle, SpawnError>

pub fn metrics(&self) -> RuntimeMetricsSnapshot

Trait Implementations§

impl Clone for RuntimeSpawner

fn clone(&self) -> RuntimeSpawner

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

Auto Trait Implementations§

impl !RefUnwindSafe for RuntimeSpawner

impl !UnwindSafe for RuntimeSpawner

impl Freeze for RuntimeSpawner

impl Send for RuntimeSpawner

impl Sync for RuntimeSpawner

impl Unpin for RuntimeSpawner

impl UnsafeUnpin for RuntimeSpawner

Blanket Implementations§

impl<T> Any for Twhere T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<T> Borrow<T> for Twhere T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for Twhere T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> CloneToUninit for Twhere T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

impl<T> From<T> for T

fn from(t: T) -> T

impl<T, U> Into<U> for Twhere U: From<T>,

fn into(self) -> U

impl<T> Pointable for T

const ALIGN: usize

type Init = T

unsafe fn init(init: <T as Pointable>::Init) -> usize

unsafe fn deref<'a>(ptr: usize) -> &'a T

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

unsafe fn drop(ptr: usize)

impl<T> ToOwned for Twhere T: Clone,

type Owned = T

fn to_owned(&self) -> T

fn clone_into(&self, target: &mut T)

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

type Error = !

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Struct RuntimeSpawner

impl<T> Any for T
where T: 'static + ?Sized,

impl<T> Borrow<T> for T
where T: ?Sized,

impl<T> BorrowMut<T> for T
where T: ?Sized,

impl<T> CloneToUninit for T
where T: Clone,

impl<T, U> Into<U> for T
where U: From<T>,

impl<T> ToOwned for T
where T: Clone,

impl<T, U> TryFrom<U> for T
where U: Into<T>,

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,