Struct lunatic_runtime::DefaultProcessState

source · [−]

pub struct DefaultProcessState { /* private fields */ }

Trait Implementations

source

impl Debug for DefaultProcessState

source

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

Formats the value using the given formatter. Read more

source

impl Default for DefaultProcessState

source

fn default() -> Self

Returns the “default value” for a type. Read more

source

impl ProcessState for DefaultProcessState

type Config = DefaultProcessConfig

source

fn new(
 runtime: WasmtimeRuntime,
 module: WasmtimeCompiledModule<Self>,
 config: Arc<DefaultProcessConfig>,
 registry: Arc<DashMap<String, Arc<dyn Process>>>
) -> Result<Self>

source

fn register(linker: &mut Linker<Self>) -> Result<()>

Register all host functions to the linker.

source

fn initialize(&mut self)

Marks a wasm instance as initialized

source

fn is_initialized(&self) -> bool

Returns true if the instance was initialized

source

fn runtime(&self) -> &WasmtimeRuntime

Returns the WebAssembly runtime

source

fn config(&self) -> &Arc<DefaultProcessConfig>

Returns the process configuration

source

fn module(&self) -> &WasmtimeCompiledModule<Self>

source

fn id(&self) -> Uuid

source

fn signal_mailbox(&self) -> &(Sender<Signal>, Receiver<Signal>)

source

fn message_mailbox(&self) -> &MessageMailbox

source

fn config_resources(
&self
) -> &ConfigResources<<DefaultProcessState as ProcessState>::Config>

source

fn config_resources_mut(
&mut self
) -> &mut ConfigResources<<DefaultProcessState as ProcessState>::Config>

source

fn registry(&self) -> &Arc<DashMap<String, Arc<dyn Process>>>

source

impl ResourceLimiter for DefaultProcessState

source

fn memory_growing(
 &mut self,
 _current: usize,
 desired: usize,
 _maximum: Option<usize>
) -> bool

Notifies the resource limiter that an instance’s linear memory has been requested to grow. Read more

source

fn table_growing(
 &mut self,
 _current: u32,
 desired: u32,
 _maximum: Option<u32>
) -> bool

Notifies the resource limiter that an instance’s table has been requested to grow. Read more

source

fn instances(&self) -> usize

The maximum number of instances that can be created for a Store. Read more

source

fn tables(&self) -> usize

The maximum number of tables that can be created for a Store. Read more

source

fn memories(&self) -> usize

The maximum number of linear memories that can be created for a Store Read more

source

fn memory_grow_failed(&mut self, _error: &Error)

Notifies the resource limiter that growing a linear memory, permitted by the memory_growing method, has failed. Read more

source

fn table_grow_failed(&mut self, _error: &Error)

Notifies the resource limiter that growing a linear memory, permitted by the table_growing method, has failed. Read more

Auto Trait Implementations

impl !RefUnwindSafe for DefaultProcessState

impl Send for DefaultProcessState

impl Sync for DefaultProcessState

impl Unpin for DefaultProcessState

impl !UnwindSafe for DefaultProcessState

Blanket Implementations

source

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

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

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

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

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

const: unstable · source

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

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

impl<T> GetSetFdFlags for T

fn get_fd_flags(&self) -> Result<FdFlags, Error> where
T: AsFilelike,

Query the “status” flags for the self file descriptor.

fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error> where
T: AsFilelike,

Create a new SetFdFlags value for use with set_fd_flags. Read more

fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error> where
T: AsFilelike,

Set the “status” flags for the self file descriptor. Read more

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

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

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

impl<T> Pointable for T

const ALIGN: usize = mem::align_of::()

The alignment of pointer.

type Init = T

The type for initializers.

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

Initializes a with the given initializer. Read more

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

Dereferences the given pointer. Read more

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

Mutably dereferences the given pointer. Read more

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more

impl<T> Pointee for T

type Pointer = u32

fn debug(
pointer: <T as Pointee>::Pointer,
f: &mut Formatter<'_>
) -> Result<(), Error>

impl<T> Pointee for T

type Pointer = u32

fn debug(
pointer: <T as Pointee>::Pointer,
f: &mut Formatter<'_>
) -> Result<(), Error>

source

impl<T> Same<T> for T

type Output = T

Should always be Self

source

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

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

source

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

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

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

Performs the conversion.

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

fn vzip(self) -> V

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct lunatic_runtime::DefaultProcessState

Trait Implementations

impl Debug for DefaultProcessState

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

impl Default for DefaultProcessState

fn default() -> Self

impl ErrorCtx for DefaultProcessState

fn error_resources(&self) -> &ErrorResource

fn error_resources_mut(&mut self) -> &mut ErrorResource

impl LunaticWasiCtx for DefaultProcessState

fn wasi(&self) -> &WasiCtx

fn wasi_mut(&mut self) -> &mut WasiCtx

fn set_stdout(&mut self, stdout: StdoutCapture)

fn set_stderr(&mut self, stderr: StdoutCapture)

fn get_stdout(&self) -> Option<&StdoutCapture>

fn get_stderr(&self) -> Option<&StdoutCapture>

impl NetworkingCtx for DefaultProcessState

fn tcp_listener_resources(&self) -> &TcpListenerResources

fn tcp_listener_resources_mut(&mut self) -> &mut TcpListenerResources

fn tcp_stream_resources(&self) -> &TcpStreamResources

fn tcp_stream_resources_mut(&mut self) -> &mut TcpStreamResources

fn udp_resources(&self) -> &UdpResources

fn udp_resources_mut(&mut self) -> &mut UdpResources

fn dns_resources(&self) -> &DnsResources

fn dns_resources_mut(&mut self) -> &mut DnsResources

impl ProcessCtx<DefaultProcessState> for DefaultProcessState

fn mailbox(&mut self) -> &mut MessageMailbox

fn message_scratch_area(&mut self) -> &mut Option<Message>

fn module_resources(&self) -> &ModuleResources<DefaultProcessState>

fn module_resources_mut(&mut self) -> &mut ModuleResources<DefaultProcessState>

fn process_resources(&self) -> &ProcessResources

fn process_resources_mut(&mut self) -> &mut ProcessResources

impl ProcessState for DefaultProcessState

type Config = DefaultProcessConfig

fn new( runtime: WasmtimeRuntime, module: WasmtimeCompiledModule<Self>, config: Arc<DefaultProcessConfig>, registry: Arc<DashMap<String, Arc<dyn Process>>>) -> Result<Self>

fn register(linker: &mut Linker<Self>) -> Result<()>

fn initialize(&mut self)

fn is_initialized(&self) -> bool

fn runtime(&self) -> &WasmtimeRuntime

fn config(&self) -> &Arc<DefaultProcessConfig>

fn module(&self) -> &WasmtimeCompiledModule<Self>

fn id(&self) -> Uuid

fn signal_mailbox(&self) -> &(Sender<Signal>, Receiver<Signal>)

fn message_mailbox(&self) -> &MessageMailbox

fn config_resources( &self) -> &ConfigResources<<DefaultProcessState as ProcessState>::Config>

fn config_resources_mut( &mut self) -> &mut ConfigResources<<DefaultProcessState as ProcessState>::Config>

fn registry(&self) -> &Arc<DashMap<String, Arc<dyn Process>>>

impl ResourceLimiter for DefaultProcessState

fn memory_growing( &mut self, _current: usize, desired: usize, _maximum: Option<usize>) -> bool

fn table_growing( &mut self, _current: u32, desired: u32, _maximum: Option<u32>) -> bool

fn instances(&self) -> usize

fn tables(&self) -> usize

fn memories(&self) -> usize

fn memory_grow_failed(&mut self, _error: &Error)

fn table_grow_failed(&mut self, _error: &Error)

Auto Trait Implementations

impl !RefUnwindSafe for DefaultProcessState

impl Send for DefaultProcessState

impl Sync for DefaultProcessState

impl Unpin for DefaultProcessState

impl !UnwindSafe for DefaultProcessState

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> GetSetFdFlags for T

fn get_fd_flags(&self) -> Result<FdFlags, Error> where T: AsFilelike,

fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error> where T: AsFilelike,

fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error> where T: AsFilelike,

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

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

fn into(self) -> U

impl<T> Pointable for T

fn new(
runtime: WasmtimeRuntime,
module: WasmtimeCompiledModule<Self>,
config: Arc<DefaultProcessConfig>,
registry: Arc<DashMap<String, Arc<dyn Process>>>
) -> Result<Self>

fn config_resources(
&self
) -> &ConfigResources<<DefaultProcessState as ProcessState>::Config>

fn config_resources_mut(
&mut self
) -> &mut ConfigResources<<DefaultProcessState as ProcessState>::Config>

fn memory_growing(
&mut self,
_current: usize,
desired: usize,
_maximum: Option<usize>
) -> bool

fn table_growing(
&mut self,
_current: u32,
desired: u32,
_maximum: Option<u32>
) -> bool

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 get_fd_flags(&self) -> Result<FdFlags, Error> where
T: AsFilelike,

fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error> where
T: AsFilelike,

fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error> where
T: AsFilelike,

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

fn debug(
pointer: <T as Pointee>::Pointer,
f: &mut Formatter<'_>
) -> Result<(), Error>

fn debug(
pointer: <T as Pointee>::Pointer,
f: &mut Formatter<'_>
) -> Result<(), Error>

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> where
S: Into<Dispatch>,