pub struct WorkerHostRunner(/* private fields */);
Expand description
A runner returned by worker_host()
. Used to handle worker launch
requests.
This may be sent across processes via mesh.
Implementations§
Source§impl WorkerHostRunner
impl WorkerHostRunner
Sourcepub async fn run(self, factory: impl WorkerFactory)
pub async fn run(self, factory: impl WorkerFactory)
Runs the worker host until all corresponding WorkerHost
instances
have been dropped and all workers have exited.
factory
provides the set of possible workers to launch. Typically,
this will be RegisteredWorkers
.
Trait Implementations§
Source§impl Debug for WorkerHostRunner
impl Debug for WorkerHostRunner
Source§impl DefaultEncoding for WorkerHostRunner
impl DefaultEncoding for WorkerHostRunner
Source§type Encoding = TableEncoder
type Encoding = TableEncoder
The encoding to use for the serialization. Read more
Source§impl<'encoding> StructDecodeMetadata<'encoding, Resource> for WorkerHostRunner
impl<'encoding> StructDecodeMetadata<'encoding, Resource> for WorkerHostRunner
Source§const DECODERS: &'static [ErasedDecoderEntry] = _
const DECODERS: &'static [ErasedDecoderEntry] = _
The list of decoder vtables.
Source§impl StructEncodeMetadata<Resource> for WorkerHostRunner
impl StructEncodeMetadata<Resource> for WorkerHostRunner
Source§const ENCODERS: &'static [ErasedEncoderEntry] = _
const ENCODERS: &'static [ErasedEncoderEntry] = _
The list of encoder vtables.
Auto Trait Implementations§
impl Freeze for WorkerHostRunner
impl !RefUnwindSafe for WorkerHostRunner
impl Send for WorkerHostRunner
impl Sync for WorkerHostRunner
impl Unpin for WorkerHostRunner
impl !UnwindSafe for WorkerHostRunner
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> MeshField for Twhere
T: DefaultEncoding,
<T as DefaultEncoding>::Encoding: FieldEncode<T, Resource> + for<'a> FieldDecode<'a, T, Resource> + Send + Sync,
impl<T> MeshField for Twhere
T: DefaultEncoding,
<T as DefaultEncoding>::Encoding: FieldEncode<T, Resource> + for<'a> FieldDecode<'a, T, Resource> + Send + Sync,
type Encoding = <T as DefaultEncoding>::Encoding
Source§impl<T> MeshPayload for Twhere
T: DefaultEncoding + Any + Send + 'static,
<T as DefaultEncoding>::Encoding: MessageEncode<T, Resource> + for<'a> MessageDecode<'a, T, Resource> + FieldEncode<T, Resource> + for<'a> FieldDecode<'a, T, Resource> + Send + Sync,
impl<T> MeshPayload for Twhere
T: DefaultEncoding + Any + Send + 'static,
<T as DefaultEncoding>::Encoding: MessageEncode<T, Resource> + for<'a> MessageDecode<'a, T, Resource> + FieldEncode<T, Resource> + for<'a> FieldDecode<'a, T, Resource> + Send + Sync,
type Encoding = <T as DefaultEncoding>::Encoding
Source§impl<T> SerializeMessage for Twhere
T: 'static + MeshPayload + Send,
impl<T> SerializeMessage for Twhere
T: 'static + MeshPayload + Send,
Source§fn compute_message_size(&mut self, sizer: MessageSizer<'_>)
fn compute_message_size(&mut self, sizer: MessageSizer<'_>)
Computes the message size, as in
MessageEncode::compute_message_size
.Source§fn write_message(self, writer: MessageWriter<'_, '_, Resource>)
fn write_message(self, writer: MessageWriter<'_, '_, Resource>)
Writes the message, as in
MessageEncode::write_message
.Source§fn extract(self) -> <T as SerializeMessage>::Concrete
fn extract(self) -> <T as SerializeMessage>::Concrete
Extract the concrete message.