Struct Endpoint 

pub struct Endpoint { /* private fields */ }

The main entry point to the library

This object performs no I/O whatsoever. Instead, it generates a stream of packets to send via poll_transmit, and consumes incoming packets and connections-generated events via handle and handle_event.

Implementations

impl Endpoint

pub fn new( local_addr: SocketAddr, protocol: TransportProtocol, server_config: Option<Arc<HandshakeConfig>>, ) -> Self

Create a new endpoint

Returns Err if the configuration is invalid.

pub fn set_server_config(&mut self, server_config: Option<Arc<HandshakeConfig>>)

Replace the server configuration, affecting new incoming associations only

pub fn poll_transmit(&mut self) -> Option<TransportMessage<BytesMut>>

Get the next packet to transmit

pub fn get_connections_keys(&self) -> Keys<'_, SocketAddr, DTLSConn>

Get keys of Connections

pub fn get_connection_state(&self, remote: SocketAddr) -> Option<&State>

Get Connection State

pub fn connect( &mut self, remote: SocketAddr, client_config: Arc<HandshakeConfig>, initial_state: Option<State>, ) -> Result<()>

Initiate an Association

pub fn stop(&mut self, remote: SocketAddr) -> Option<DTLSConn>

Process stop remote

pub fn close(&mut self) -> Result<()>

Process close

pub fn read( &mut self, now: Instant, remote: SocketAddr, ecn: Option<EcnCodepoint>, data: BytesMut, ) -> Result<Vec<EndpointEvent>>

Process an incoming UDP datagram

pub fn write(&mut self, remote: SocketAddr, data: &[u8]) -> Result<()>

Queues application data for remote.

Errors

Fails if there is no association with remote, or its handshake has not completed.

pub fn handle_timeout(&mut self, remote: SocketAddr, now: Instant) -> Result<()>

Advances remote’s association to now, driving handshake retransmissions.

Errors

Fails if the handshake has exhausted its retransmissions.

pub fn poll_timeout(&self, remote: SocketAddr, eto: &mut Instant) -> Result<()>

When remote’s association next needs Self::handle_timeout.