ns-router 0.1.6

A configurable name resolver for abstract-ns
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43

use std::fmt;

use abstract_ns::{Name, Error, Address, IpList};
use async_slot as slot;
use futures::sync::oneshot;

use coroutine::{Continuation};


#[derive(Debug)]
pub(crate) enum Request {
    ResolveHost(Name, oneshot::Sender<Result<IpList, Error>>),
    ResolveHostPort(Name, u16, oneshot::Sender<Result<Address, Error>>),
    Resolve(Name, oneshot::Sender<Result<Address, Error>>),
    HostSubscribe(Name, slot::Sender<IpList>),
    Subscribe(Name, slot::Sender<Address>),
    Task(Box<Continuation+Send>),
}

trait AssertTraits: Send {}
impl AssertTraits for Request {}

pub fn reply<X: Send + fmt::Debug + 'static>(name: &Name,
    tx: oneshot::Sender<Result<X, Error>>, value: X)
{
    tx.send(Ok(value))
        .map_err(|value| {
            trace!("{:?} resolved into {:?} but dropped",
                name, value.unwrap());
        })
        .ok();
}

pub fn fail<X: fmt::Debug>(name: &Name,
    tx: oneshot::Sender<Result<X, Error>>, error: Error)
{
    tx.send(Err(error))
        .map_err(|err| {
            trace!("{:?} resolved into, error but dropped: {}",
                name, err.unwrap_err());
        })
        .ok();
}