pub async fn create_coordinator_server<A>(
    addr: A
) -> Result<CoordinatorServer, Error>
where A: ToSocketAddrs,