Struct rpki_rtr::server::Server

pub struct Server<Listener, Source> { /* private fields */ }

An RTR server.

The server takes a stream socket listener – a stream of new sockets – and a VRP source and serves RTR data. In order to also serve notifications whenever new data is available, the server uses a notification dispatch system via the Dispatch system.

Implementations

impl<Listener, Source> Server<Listener, Source>

pub fn new(listener: Listener, notify: NotifySender, source: Source) -> Self

Creates a new RTR server from its components.

pub async fn run<Sock>(self) -> Result<(), Error>where
    Listener: Stream<Item = Result<Sock, Error>> + Unpin,
    Sock: AsyncRead + AsyncWrite + Unpin + Sync + Send + 'static,
    Source: VrpSource,

Runs the server.

The asynchronous function will return successfully when the listener socket (which is a stream over new connectons) finishes. It will return with an error if the listener socket errors out.