Struct Endpoint 

pub struct Endpoint<S, Q> { /* private fields */ }

The main entry point to the library

This object performs no I/O whatsoever. Instead, it consumes incoming packets and connection-generated events via handle and handle_event.

Implementations

impl<S, Q> Endpoint<S, Q>

where S: Pool<Q>, Q: Pool<u16>,

pub fn new() -> Self

Create a new server endpoint

pub fn with_capacity(capacity: usize) -> Result<Self, S::Error>

Create a new server endpoint with a specific capacity

pub fn close(&mut self)

Close the endpoint

pub fn accept(&mut self) -> Result<ConnectionHandle, Error<S::Error, Q::Error>>

Accept a new connection

pub fn recv<'container, 'innards>( &mut self, ch: ConnectionHandle, msg: Message<'container, 'innards>, ) -> Result<Query<'container, 'innards>, Error<S::Error, Q::Error>>

Handle an incoming query message

pub fn response( &mut self, qh: QueryHandle, question: Question<'_>, ) -> Result<Outgoing, Error<S::Error, Q::Error>>

Generate a response for a question

pub fn drain_query( &mut self, qh: QueryHandle, ) -> Result<(), Error<S::Error, Q::Error>>

Handle a query drain event

pub fn drain_connection( &mut self, ch: ConnectionHandle, ) -> Result<Closed<Q>, Error<S::Error, Q::Error>>

Handle a connection drain event

Trait Implementations

impl<S, Q> Default for Endpoint<S, Q>

where S: Pool<Q>, Q: Pool<u16>,

fn default() -> Self

Returns the “default value” for a type.