Struct DhtConfig 

pub struct DhtConfig {
    pub kbucket_pending_timeout: Duration,
    pub local_id: Option<[u8; 32]>,
    pub commands: HashSet<usize>,
    pub query_config: QueryConfig,
    pub io_config: IoConfig,
    pub bootstrap_interval: Duration,
    pub ping_interval: Duration,
    pub connection_idle_timeout: Duration,
    pub adaptive: bool,
    pub bootstrap_nodes: Vec<SocketAddr>,
    pub socket: Option<MessageDataStream>,
}

Fields

kbucket_pending_timeout: Duration

local_id: Option<[u8; 32]>

commands: HashSet<usize>

query_config: QueryConfig

io_config: IoConfig

bootstrap_interval: Duration

ping_interval: Duration

connection_idle_timeout: Duration

adaptive: bool

bootstrap_nodes: Vec<SocketAddr>

socket: Option<MessageDataStream>

Implementations

impl DhtConfig

pub fn bind<A: ToSocketAddrs>(self, addr: A) -> Result<Self>

Create a new UDP socket and attempt to bind it to the addr provided.

pub fn add_bootstrap_node<A: Into<SocketAddr>>(self, addr: A) -> Self

pub fn empty_bootstrap_nodes(self) -> Self

pub fn set_bootstrap_nodes<T: ToSocketAddrs>(self, addresses: &[T]) -> Self

Set the nodes to bootstrap from

pub fn register_commands(self, cmds: &[usize]) -> Self

Register all commands to listen to.

pub fn set_ephemeral(self, ephemeral: bool) -> Self

Set ephemeral value. When true this node won’t expose its id to remote peer, so other peers do not add us to the peer list.

Trait Implementations

impl Debug for DhtConfig

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for DhtConfig

fn default() -> Self

Returns the “default value” for a type.