Struct ockam::WorkerSystem

source · [−]

pub struct WorkerSystem<W: Worker> { /* private fields */ }

Expand description

A componasble worker system type

A worker system is a single worker which can act as a full cluster of workers. This is achieved via the send_to_self(...) API endpoint on the Ockam Node API.

The worker system also provides some utilities for creating and managing mappings between hidden API-addresses and behaviour hooks associated to each address.

The advantage of a worker system over a full set of workers is a lower memory overhead for resource constrained devices.

Struct ockam::WorkerSystem

Implementations

impl<W: Worker> WorkerSystem<W>

pub fn attach<A, H>(&mut self, addr: A, handler: H) where A: Into<Address>, H: SystemHandler<W::Context, W::Message> + Send + 'static,

pub async fn handle_message( &mut self, ctx: &mut W::Context, msg: Routed<W::Message>) -> Result<()>

Trait Implementations

impl<W: Worker> Default for WorkerSystem<W>

fn default() -> Self

Auto Trait Implementations

impl<W> !RefUnwindSafe for WorkerSystem<W>

impl<W> Send for WorkerSystem<W>

impl<W> !Sync for WorkerSystem<W>

impl<W> Unpin for WorkerSystem<W>

impl<W> !UnwindSafe for WorkerSystem<W>

Blanket Implementations

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

fn type_id(&self) -> TypeId

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

fn borrow(&self) -> &T

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

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

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;

fn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;

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

fn into(self) -> U

impl<T> Same<T> for T

type Output = T

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

type Error = Infallible

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

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

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

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

impl<V, T> VZip<V> for T where V: MultiLane<T>,

fn vzip(self) -> V

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output; where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;

pub fn attach<A, H>(&mut self, addr: A, handler: H) where
A: Into<Address>,
H: SystemHandler<W::Context, W::Message> + Send + 'static,

pub async fn handle_message(
&mut self,
ctx: &mut W::Context,
msg: Routed<W::Message>
) -> Result<()>

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,

fn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>`impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;`

fn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>`impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;`

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

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

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

impl<V, T> VZip<V> for T where
V: MultiLane<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>`impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;` where
S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>`impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;`