Struct daemon_engine::server::Server

pub struct Server<T: AsyncRead + AsyncWrite, C: Encoder + Decoder, I> { /* private fields */ }

Server provides a generic base for building stream servers.

This is generic over T, a stream reader and writer, C, and encoder and decoder, and I, and information object.

You probably want to be looking at TcpServer and UnixServer implementations

Implementations

impl<T, C, I> Server<T, C, I>where
    T: AsyncWrite + AsyncRead + Send + Sync + 'static,
    C: Encoder + Decoder + Default + Send + 'static,
    I: Clone + Send + Debug + 'static,
    <C as Decoder>::Item: Clone + Send + Debug,
    <C as Decoder>::Error: Send + Debug,
    <C as Encoder>::Item: Clone + Send + Debug,
    <C as Encoder>::Error: Send + Debug,

pub fn base() -> Server<T, C, I>

Create a new base server with defined request and response message types.

This sets up internal resources however requires implementation to handle creating listeners and binding connections See TcpServer and UnixServer for examples

pub fn incoming(&mut self) -> Option<UnboundedReceiver<Request<T, C, I>>>

Take the incoming data handle.

You can then use for_each to iterate over received requests as in the examples

pub fn bind(&mut self, info: I, socket: T)

Bind a socket to a server.

This attaches an rx handler to the server, and can be used both for server listener implementations as well as to support server-initialised connections if required

pub fn close(self)

Close the socket server

This sends exit messages to the main task and all connected hosts

impl<C> Server<TcpStream, C, TcpInfo>where
    C: Encoder + Decoder + Default + Send + 'static,
    <C as Decoder>::Item: Clone + Send + Debug,
    <C as Decoder>::Error: Send + Debug,
    <C as Encoder>::Item: Clone + Send + Debug,
    <C as Encoder>::Error: Send + Debug,

TCP server implementation.

pub fn new(address: &SocketAddr) -> Result<TcpServer<C>, Error>

pub fn connect(&mut self, address: &SocketAddr) -> Result<(), Error>

impl<C> Server<UnixStream, C, UnixInfo>where
    C: Encoder + Decoder + Default + Send + 'static,
    <C as Decoder>::Item: Clone + Send + Debug,
    <C as Decoder>::Error: Send + Debug,
    <C as Encoder>::Item: Clone + Send + Debug,
    <C as Encoder>::Error: Send + Debug,

Unix server implementation

This binds to and listens on a unix domain socket

pub fn new(path: &str) -> Result<UnixServer<C>, Error>

pub fn shutdown(&self)

Trait Implementations

impl<T, C, I> Clone for Server<T, C, I>where
    T: AsyncWrite + AsyncRead + Send + Sync + 'static,
    C: Encoder + Decoder + Default + Send + 'static,
    I: Clone + Send + Debug + 'static,
    <C as Decoder>::Item: Clone + Send + Debug,
    <C as Decoder>::Error: Send + Debug,
    <C as Encoder>::Item: Clone + Send + Debug,
    <C as Encoder>::Error: Send + Debug,

Clone over generic connector

All instances of a given connector contain the same arc/mutex protected information

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.