Struct SpinSocketsView 

pub struct SpinSocketsView<'a, T> { /* private fields */ }

A view over WASI socket state that carries an optional per-instance socket permit store, enabling per-connection quota tracking.

Implementations

impl<'a, T> SpinSocketsView<'a, T>

pub fn into_wasi(self) -> WasiSocketsCtxView<'a>

Consumes this view and returns the inner WasiSocketsCtxView.

Trait Implementations

impl<'a, T> Deref for SpinSocketsView<'a, T>

type Target = WasiSocketsCtxView<'a>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl<T> DerefMut for SpinSocketsView<'_, T>

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.

impl<T> Host for SpinSocketsView<'_, T>

impl<T> Host for SpinSocketsView<'_, T>

fn convert_error_code(&mut self, error: SocketError) -> Result<ErrorCode>

fn network_error_code( &mut self, err: Resource<Error>, ) -> Result<Option<ErrorCode>>

Attempts to extract a network-related error-code from the stream error provided.

impl<T> Host for SpinSocketsView<'_, T>

fn create_tcp_socket( &mut self, address_family: IpAddressFamily, ) -> SocketResult<Resource<TcpSocket>>

Create a new TCP socket.

impl<T> Host for SpinSocketsView<'_, T>

impl<T> Host for SpinSocketsView<'_, T>

fn create_udp_socket( &mut self, address_family: IpAddressFamily, ) -> SocketResult<Resource<UdpSocket>>

Create a new UDP socket.

impl<T> Host for SpinSocketsView<'_, T>

fn convert_error_code(&mut self, error: SocketError) -> Result<p3_ErrorCode>

impl<T> HostIncomingDatagramStream for SpinSocketsView<'_, T>

fn receive( &mut self, this: Resource<IncomingDatagramStream>, max_results: u64, ) -> SocketResult<Vec<IncomingDatagram>>

Receive messages on the socket.

fn subscribe( &mut self, this: Resource<IncomingDatagramStream>, ) -> Result<Resource<DynPollable>>

Create a pollable which will resolve once the stream is ready to receive again.

fn drop(&mut self, this: Resource<IncomingDatagramStream>) -> Result<()>

impl<T> HostNetwork for SpinSocketsView<'_, T>

fn drop(&mut self, this: Resource<Network>) -> Result<()>

impl<T> HostOutgoingDatagramStream for SpinSocketsView<'_, T>

fn check_send( &mut self, this: Resource<OutgoingDatagramStream>, ) -> SocketResult<u64>

Check readiness for sending. This function never blocks.

async fn send( &mut self, this: Resource<OutgoingDatagramStream>, datagrams: Vec<OutgoingDatagram>, ) -> SocketResult<u64>

Send messages on the socket.

fn subscribe( &mut self, this: Resource<OutgoingDatagramStream>, ) -> Result<Resource<DynPollable>>

Create a pollable which will resolve once the stream is ready to send again.

fn drop(&mut self, this: Resource<OutgoingDatagramStream>) -> Result<()>

impl<T> HostTcpSocket for SpinSocketsView<'_, T>

async fn start_bind( &mut self, this: Resource<TcpSocket>, network: Resource<Network>, local_address: IpSocketAddress, ) -> SocketResult<()>

Bind the socket to a specific network on the provided IP address and port.

fn finish_bind(&mut self, this: Resource<TcpSocket>) -> SocketResult<()>

async fn start_connect( &mut self, this: Resource<TcpSocket>, network: Resource<Network>, remote_address: IpSocketAddress, ) -> SocketResult<()>

Connect to a remote endpoint.

fn finish_connect( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<(Resource<DynInputStream>, Resource<DynOutputStream>)>

fn start_listen(&mut self, this: Resource<TcpSocket>) -> SocketResult<()>

Start listening for new connections.

fn finish_listen(&mut self, this: Resource<TcpSocket>) -> SocketResult<()>

fn accept( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<(Resource<TcpSocket>, Resource<DynInputStream>, Resource<DynOutputStream>)>

Accept a new client socket.

fn local_address( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<IpSocketAddress>

Get the bound local address.

fn remote_address( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<IpSocketAddress>

Get the remote address.

fn is_listening(&mut self, this: Resource<TcpSocket>) -> Result<bool>

Whether the socket is in the listening state.

fn address_family( &mut self, this: Resource<TcpSocket>, ) -> Result<IpAddressFamily>

Whether this is a IPv4 or IPv6 socket.

fn set_listen_backlog_size( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

Hints the desired listen queue size. Implementations are free to ignore this.

fn keep_alive_enabled( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<bool>

Enables or disables keepalive.

fn set_keep_alive_enabled( &mut self, this: Resource<TcpSocket>, value: bool, ) -> SocketResult<()>

fn keep_alive_idle_time( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<u64>

Amount of time the connection has to be idle before TCP starts sending keepalive packets.

fn set_keep_alive_idle_time( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn keep_alive_interval( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<u64>

The time between keepalive packets.

fn set_keep_alive_interval( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn keep_alive_count(&mut self, this: Resource<TcpSocket>) -> SocketResult<u32>

The maximum amount of keepalive packets TCP should send before aborting the connection.

fn set_keep_alive_count( &mut self, this: Resource<TcpSocket>, value: u32, ) -> SocketResult<()>

fn hop_limit(&mut self, this: Resource<TcpSocket>) -> SocketResult<u8>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_hop_limit( &mut self, this: Resource<TcpSocket>, value: u8, ) -> SocketResult<()>

fn receive_buffer_size( &mut self, this: Resource<TcpSocket>, ) -> SocketResult<u64>

The kernel buffer space reserved for sends/receives on this socket.

fn set_receive_buffer_size( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn send_buffer_size(&mut self, this: Resource<TcpSocket>) -> SocketResult<u64>

fn set_send_buffer_size( &mut self, this: Resource<TcpSocket>, value: u64, ) -> SocketResult<()>

fn subscribe( &mut self, this: Resource<TcpSocket>, ) -> Result<Resource<DynPollable>>

Create a pollable which can be used to poll for, or block on, completion of any of the asynchronous operations of this socket.

fn shutdown( &mut self, this: Resource<TcpSocket>, shutdown_type: ShutdownType, ) -> SocketResult<()>

Initiate a graceful shutdown.

fn drop(&mut self, this: Resource<TcpSocket>) -> Result<()>

impl<T> HostTcpSocket for SpinSocketsView<'_, T>

async fn bind( &mut self, socket: Resource<TcpSocket>, local_address: p3_IpSocketAddress, ) -> P3SocketResult<()>

Bind the socket to the provided IP address and port.

fn create( &mut self, address_family: p3_IpAddressFamily, ) -> P3SocketResult<Resource<TcpSocket>>

Create a new TCP socket.

fn get_local_address( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<p3_IpSocketAddress>

Get the bound local address.

fn get_remote_address( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<p3_IpSocketAddress>

Get the remote address.

fn get_is_listening(&mut self, socket: Resource<TcpSocket>) -> Result<bool>

Whether the socket is in the listening state.

fn get_address_family( &mut self, socket: Resource<TcpSocket>, ) -> Result<p3_IpAddressFamily>

Whether this is a IPv4 or IPv6 socket.

fn set_listen_backlog_size( &mut self, socket: Resource<TcpSocket>, value: u64, ) -> P3SocketResult<()>

Hints the desired listen queue size. Implementations are free to ignore this.

fn get_keep_alive_enabled( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<bool>

Enables or disables keepalive.

fn set_keep_alive_enabled( &mut self, socket: Resource<TcpSocket>, value: bool, ) -> P3SocketResult<()>

fn get_keep_alive_idle_time( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<p3_Duration>

Amount of time the connection has to be idle before TCP starts sending keepalive packets.

fn set_keep_alive_idle_time( &mut self, socket: Resource<TcpSocket>, value: p3_Duration, ) -> P3SocketResult<()>

fn get_keep_alive_interval( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<p3_Duration>

The time between keepalive packets.

fn set_keep_alive_interval( &mut self, socket: Resource<TcpSocket>, value: p3_Duration, ) -> P3SocketResult<()>

fn get_keep_alive_count( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<u32>

The maximum amount of keepalive packets TCP should send before aborting the connection.

fn set_keep_alive_count( &mut self, socket: Resource<TcpSocket>, value: u32, ) -> P3SocketResult<()>

fn get_hop_limit(&mut self, socket: Resource<TcpSocket>) -> P3SocketResult<u8>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_hop_limit( &mut self, socket: Resource<TcpSocket>, value: u8, ) -> P3SocketResult<()>

fn get_receive_buffer_size( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<u64>

Kernel buffer space reserved for sending/receiving on this socket. Implementations usually treat this as a cap the buffer can grow to, rather than allocating the full amount immediately.

fn set_receive_buffer_size( &mut self, socket: Resource<TcpSocket>, value: u64, ) -> P3SocketResult<()>

fn get_send_buffer_size( &mut self, socket: Resource<TcpSocket>, ) -> P3SocketResult<u64>

fn set_send_buffer_size( &mut self, socket: Resource<TcpSocket>, value: u64, ) -> P3SocketResult<()>

fn drop(&mut self, sock: Resource<TcpSocket>) -> Result<()>

impl<T> HostUdpSocket for SpinSocketsView<'_, T>

async fn start_bind( &mut self, this: Resource<UdpSocket>, network: Resource<Network>, local_address: IpSocketAddress, ) -> SocketResult<()>

Bind the socket to a specific network on the provided IP address and port.

fn finish_bind(&mut self, this: Resource<UdpSocket>) -> SocketResult<()>

async fn stream( &mut self, this: Resource<UdpSocket>, remote_address: Option<IpSocketAddress>, ) -> SocketResult<(Resource<IncomingDatagramStream>, Resource<OutgoingDatagramStream>)>

Set up inbound & outbound communication channels, optionally to a specific peer.

fn local_address( &mut self, this: Resource<UdpSocket>, ) -> SocketResult<IpSocketAddress>

Get the current bound address.

fn remote_address( &mut self, this: Resource<UdpSocket>, ) -> SocketResult<IpSocketAddress>

Get the address the socket is currently streaming to.

fn address_family( &mut self, this: Resource<UdpSocket>, ) -> Result<IpAddressFamily>

Whether this is a IPv4 or IPv6 socket.

fn unicast_hop_limit(&mut self, this: Resource<UdpSocket>) -> SocketResult<u8>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_unicast_hop_limit( &mut self, this: Resource<UdpSocket>, value: u8, ) -> SocketResult<()>

fn receive_buffer_size( &mut self, this: Resource<UdpSocket>, ) -> SocketResult<u64>

The kernel buffer space reserved for sends/receives on this socket.

fn set_receive_buffer_size( &mut self, this: Resource<UdpSocket>, value: u64, ) -> SocketResult<()>

fn send_buffer_size(&mut self, this: Resource<UdpSocket>) -> SocketResult<u64>

fn set_send_buffer_size( &mut self, this: Resource<UdpSocket>, value: u64, ) -> SocketResult<()>

fn subscribe( &mut self, this: Resource<UdpSocket>, ) -> Result<Resource<DynPollable>>

Create a pollable which will resolve once the socket is ready for I/O.

fn drop(&mut self, this: Resource<UdpSocket>) -> Result<()>

impl<T> HostUdpSocket for SpinSocketsView<'_, T>

async fn bind( &mut self, socket: Resource<UdpSocket>, local_address: p3_IpSocketAddress, ) -> P3SocketResult<()>

Bind the socket to the provided IP address and port.

async fn connect( &mut self, socket: Resource<UdpSocket>, remote_address: p3_IpSocketAddress, ) -> P3SocketResult<()>

Associate this socket with a specific peer address.

fn create( &mut self, address_family: p3_IpAddressFamily, ) -> P3SocketResult<Resource<UdpSocket>>

Create a new UDP socket.

fn disconnect(&mut self, socket: Resource<UdpSocket>) -> P3SocketResult<()>

Dissociate this socket from its peer address.

fn get_local_address( &mut self, socket: Resource<UdpSocket>, ) -> P3SocketResult<p3_IpSocketAddress>

Get the current bound address.

fn get_remote_address( &mut self, socket: Resource<UdpSocket>, ) -> P3SocketResult<p3_IpSocketAddress>

Get the address the socket is currently “connected” to.

fn get_address_family( &mut self, socket: Resource<UdpSocket>, ) -> Result<p3_IpAddressFamily>

Whether this is a IPv4 or IPv6 socket.

fn get_unicast_hop_limit( &mut self, socket: Resource<UdpSocket>, ) -> P3SocketResult<u8>

Equivalent to the IP_TTL & IPV6_UNICAST_HOPS socket options.

fn set_unicast_hop_limit( &mut self, socket: Resource<UdpSocket>, value: u8, ) -> P3SocketResult<()>

fn get_receive_buffer_size( &mut self, socket: Resource<UdpSocket>, ) -> P3SocketResult<u64>

Kernel buffer space reserved for sending/receiving on this socket. Implementations usually treat this as a cap the buffer can grow to, rather than allocating the full amount immediately.

fn set_receive_buffer_size( &mut self, socket: Resource<UdpSocket>, value: u64, ) -> P3SocketResult<()>

fn get_send_buffer_size( &mut self, socket: Resource<UdpSocket>, ) -> P3SocketResult<u64>

fn set_send_buffer_size( &mut self, socket: Resource<UdpSocket>, value: u64, ) -> P3SocketResult<()>

fn drop(&mut self, sock: Resource<UdpSocket>) -> Result<()>