Struct DnodeProxy 

pub struct DnodeProxy { /* private fields */ }

DNODE_PEER_PROXY listener.

Implementations

impl DnodeProxy

pub fn bind<A: Into<SocketAddr>>(addr: A) -> Result<Self, NetError>

Bind a peer-listener to the given address.

Errors

Forwarded from the underlying socket calls.

pub fn with_tls(self, acceptor: TlsAcceptor) -> Self

Attach a TLS acceptor; every accepted peer is wrapped via TlsAcceptor::accept before being handed off to the per-peer driver. When the acceptor is unset (the default) the listener serves plaintext TCP, matching the historical behaviour.

pub fn has_tls(&self) -> bool

True when the listener is configured with a TLS acceptor.

pub fn local_addr(&self) -> Result<SocketAddr>

Local address of the listener.

pub async fn run<F>( self, cancel: Pin<Box<dyn Future<Output = ()> + Send>>, handler_factory: F, ) -> Result<(), NetError>

where F: FnMut(Sender<OutboundEnvelope>) -> ClientHandler + Send,

Drive the accept loop. The supplied handler_factory is called once per accepted peer; it receives the per-connection responder sender (the matching half of the channel the inbound driver reads from) and returns the ClientHandler the per-peer loop should use.

Errors

Forwarded from the listener accept call.