Struct WasiSockets 

pub struct WasiSockets;

A helper struct which implements HasData for the wasi:sockets APIs.

This can be useful when directly calling add_to_linker functions directly, such as [wasmtime_wasi::p2::bindings::sockets::tcp::add_to_linker] as the D type parameter. See HasData for more information about the type parameter’s purpose.

When using this type you can skip the WasiSocketsView trait, for example.

Examples

use wasmtime::component::{Linker, ResourceTable};
use wasmtime::{Engine, Result, Config};
use wasmtime_wasi::sockets::*;

struct MyStoreState {
    table: ResourceTable,
    sockets: WasiSocketsCtx,
}

fn main() -> Result<()> {
    let mut config = Config::new();
    config.async_support(true);
    let engine = Engine::new(&config)?;
    let mut linker = Linker::new(&engine);

    wasmtime_wasi::p2::bindings::sockets::tcp::add_to_linker::<MyStoreState, WasiSockets>(
        &mut linker,
        |state| WasiSocketsCtxView {
            ctx: &mut state.sockets,
            table: &mut state.table,
        },
    )?;
    Ok(())
}

Trait Implementations

impl HasData for WasiSockets

type Data<'a> = WasiSocketsCtxView<'a>

The data associated with this trait implementation, chiefly used as a generic associated type to allow plumbing the 'a lifetime into the definition here.

impl HostTcpSocketWithStore for WasiSockets

Available on crate feature p3 only.

async fn bind<T>( store: &Accessor<T, Self>, socket: Resource<TcpSocket>, local_address: IpSocketAddress, ) -> SocketResult<()>

Bind the socket to the provided IP address and port.

async fn connect<T>( store: &Accessor<T, Self>, socket: Resource<TcpSocket>, remote_address: IpSocketAddress, ) -> SocketResult<()>

Connect to a remote endpoint.

async fn listen<T: 'static>( store: &Accessor<T, Self>, socket: Resource<TcpSocket>, ) -> SocketResult<StreamReader<Resource<TcpSocket>>>

Start listening and return a stream of new inbound connections.

async fn send<T: 'static>( store: &Accessor<T, Self>, socket: Resource<TcpSocket>, data: StreamReader<u8>, ) -> SocketResult<()>

Transmit data to peer.

async fn receive<T: 'static>( store: &Accessor<T, Self>, socket: Resource<TcpSocket>, ) -> Result<(StreamReader<u8>, FutureReader<Result<(), ErrorCode>>)>

Read data from peer.

impl HostUdpSocketWithStore for WasiSockets

Available on crate feature p3 only.

async fn bind<T>( store: &Accessor<T, Self>, socket: Resource<UdpSocket>, local_address: IpSocketAddress, ) -> SocketResult<()>

Bind the socket to the provided IP address and port.

async fn connect<T>( store: &Accessor<T, Self>, socket: Resource<UdpSocket>, remote_address: IpSocketAddress, ) -> SocketResult<()>

Associate this socket with a specific peer address.

async fn send<T>( store: &Accessor<T, Self>, socket: Resource<UdpSocket>, data: Vec<u8>, remote_address: Option<IpSocketAddress>, ) -> SocketResult<()>

Send a message on the socket to a particular peer.

async fn receive<T>( store: &Accessor<T, Self>, socket: Resource<UdpSocket>, ) -> SocketResult<(Vec<u8>, IpSocketAddress)>

Receive a message on the socket.

impl HostWithStore for WasiSockets

Available on crate feature p3 only.

async fn resolve_addresses<U>( store: &Accessor<U, Self>, name: String, ) -> Result<Result<Vec<IpAddress>, ErrorCode>>

Resolve an internet host name to a list of IP addresses.