Struct wasmer_wasix::runners::dproxy::socket_manager::SocketManager

pub struct SocketManager {
    poll_listening: Arc<dyn Fn(&mut Context<'_>) -> Poll<SocketAddr> + Send + Sync + 'static>,
    loopback_networking: LoopbackNetworking,
    proxy_connect_init_timeout: Duration,
    proxy_connect_nominal_timeout: Duration,
    is_running: AtomicBool,
    is_terminated: AtomicBool,
    terminate_all: Sender<()>,
}

Fields

poll_listening: Arc<dyn Fn(&mut Context<'_>) -> Poll<SocketAddr> + Send + Sync + 'static>

loopback_networking: LoopbackNetworking

proxy_connect_init_timeout: Duration

proxy_connect_nominal_timeout: Duration

is_running: AtomicBool

is_terminated: AtomicBool

terminate_all: Sender<()>

Implementations

impl SocketManager

pub fn new( poll_listening: Arc<dyn Fn(&mut Context<'_>) -> Poll<SocketAddr> + Send + Sync + 'static>, loopback_networking: LoopbackNetworking, proxy_connect_init_timeout: Duration, proxy_connect_nominal_timeout: Duration, ) -> Self

pub fn shutdown(&self)

pub fn terminate_rx(&self) -> Receiver<()>

pub async fn acquire_http_socket(&self) -> Result<TcpSocketHalf>

pub async fn open_proxy_http_socket(&self) -> Result<TcpSocketHalf>

Trait Implementations

impl Debug for SocketManager

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

Formats the value using the given formatter.