Struct Server 

pub struct Server<C> {
    pub router: Router<C>,
    pub key: ListenerKey,
    pub allow_non_in: bool,
    pub debug: bool,
    pub udp_workers: usize,
    pub logger: fn(Error),
    /* private fields */
}

One Listener’s routing, admission and Plugin Chain execution.

Fields

router: Router<C>

key: ListenerKey

allow_non_in: bool

debug: bool

udp_workers: usize

logger: fn(Error)

Implementations

impl<C: Chain> Server<C>

pub fn new(router: Router<C>, key: ListenerKey) -> Self

pub fn with_registry( router: Router<C>, key: ListenerKey, metrics: Registry, ) -> Self

pub fn metrics(&self) -> &Registry

Trait Implementations

impl<C: Chain> Handler for Server<C>

fn udp_workers(&self) -> usize

Number of UDP worker sockets for this Listener.

fn parallel_query( &self, wire: &[u8], peer: SocketAddr, ) -> Option<Receiver<bool>>

Whether this HINFO Query must run concurrently with UDP reception.

async fn handle( &self, wire: &[u8], peer: SocketAddr, protocol: Protocol, response: &mut Vec<u8>, ) -> Action

async fn handle_shared( self: &Arc<Self>, wire: &[u8], peer: SocketAddr, protocol: Protocol, response: &mut Vec<u8>, ) -> Action

Handle a Query while retaining access to the Listener’s owned state.