Struct tari_comms_dht::DhtBuilder

pub struct DhtBuilder { /* fields omitted */ }

Implementations

impl DhtBuilder

pub fn new(
    node_identity: Arc<NodeIdentity>,
    peer_manager: Arc<PeerManager>,
    outbound_tx: Sender<DhtOutboundRequest>,
    connectivity: ConnectivityRequester,
    shutdown_signal: ShutdownSignal
) -> Self

pub fn with_config(mut self: Self, config: DhtConfig) -> Self

pub fn local_test(mut self: Self) -> Self

pub fn set_auto_store_and_forward_requests(
    mut self: Self,
    enabled: bool
) -> Self

pub fn testnet(mut self: Self) -> Self

pub fn mainnet(mut self: Self) -> Self

pub fn with_database_url(mut self: Self, database_url: DbConnectionUrl) -> Self

pub fn with_signature_cache_ttl(mut self: Self, ttl: Duration) -> Self

pub fn with_signature_cache_capacity(mut self: Self, capacity: usize) -> Self

pub fn with_num_random_nodes(mut self: Self, n: usize) -> Self

pub fn with_num_neighbouring_nodes(mut self: Self, n: usize) -> Self

pub fn with_propagation_factor(
    mut self: Self,
    propagation_factor: usize
) -> Self

pub fn with_broadcast_factor(mut self: Self, broadcast_factor: usize) -> Self

pub fn with_discovery_timeout(mut self: Self, timeout: Duration) -> Self

pub fn enable_auto_join(mut self: Self) -> Self

pub async fn build(self) -> Result<Dht, DhtInitializationError>

Build and initialize a Dht object.

Will panic not in a tokio runtime context