Struct agilulf::Server

pub struct Server { /* fields omitted */ }

A simple TCP server constructed by a foreign database with the help of agilulf_protocol

Most of it's coded are neccesary and template. There isn't much logic code in this mod:

First, set up a romio TCP server and spawn every connection on a ThreadPool.

For every connection, convert the Incoming stream into command stream and send the command to database. Then read reply from database (actually not read, it is just function return). Send the reply to reply sink (converted from outcoming sink)

This struct just assemble the protocol and database together. With this template, implement a KV server on another transimission layer is quite the same. Just replace the romio TCP server with other asynchronous server and most codes are same.

Methods

impl Server

pub fn new(
    address: &str,
    database: impl AsyncDatabase + 'static
) -> Result<Server, ServerError>

pub async fn run_async(__arg0: Self) -> Result<(), ServerError>

run_async is provided as a seperated function. Becasue you may want to run on a ThreadPool or any other executor. I don't want to limit the executor choice.

pub fn run(self) -> Result<(), ServerError>

This function use futures::executor::block_on to run method run_async