mirror of
https://github.com/fluencelabs/rust-libp2p
synced 2025-04-25 03:02:12 +00:00
Add function to get neighborhood locally (#40)
This commit is contained in:
parent
25fa799cc2
commit
159cb6b2ca
40
Cargo.toml
40
Cargo.toml
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p"
|
name = "fluence-fork-libp2p"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Peer-to-peer networking library"
|
description = "Peer-to-peer networking library"
|
||||||
version = "0.34.0"
|
version = "0.34.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -64,33 +64,33 @@ atomic = "0.5.0"
|
|||||||
bytes = "0.5"
|
bytes = "0.5"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
lazy_static = "1.2"
|
lazy_static = "1.2"
|
||||||
libp2p-core = { version = "0.26.0", path = "core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "core", package = "fluence-fork-libp2p-core" }
|
||||||
libp2p-core-derive = { version = "0.21.0", path = "misc/core-derive", package = "fluence-fork-libp2p-core-derive" }
|
libp2p-core-derive = { version = "0.21.1", path = "misc/core-derive", package = "fluence-fork-libp2p-core-derive" }
|
||||||
libp2p-floodsub = { version = "0.26.0", path = "protocols/floodsub", optional = true, package = "fluence-fork-libp2p-floodsub" }
|
libp2p-floodsub = { version = "0.26.1", path = "protocols/floodsub", optional = true, package = "fluence-fork-libp2p-floodsub" }
|
||||||
libp2p-gossipsub = { version = "0.26.0", path = "./protocols/gossipsub", optional = true, package = "fluence-fork-libp2p-gossipsub" }
|
libp2p-gossipsub = { version = "0.26.1", path = "./protocols/gossipsub", optional = true, package = "fluence-fork-libp2p-gossipsub" }
|
||||||
libp2p-identify = { version = "0.26.0", path = "protocols/identify", optional = true, package = "fluence-fork-libp2p-identify" }
|
libp2p-identify = { version = "0.26.1", path = "protocols/identify", optional = true, package = "fluence-fork-libp2p-identify" }
|
||||||
libp2p-kad = { version = "0.27.0", path = "protocols/kad", optional = true, package = "fluence-fork-libp2p-kad" }
|
libp2p-kad = { version = "0.27.0", path = "protocols/kad", optional = true, package = "fluence-fork-libp2p-kad" }
|
||||||
libp2p-mplex = { version = "0.26.0", path = "muxers/mplex", optional = true, package = "fluence-fork-libp2p-mplex" }
|
libp2p-mplex = { version = "0.26.1", path = "muxers/mplex", optional = true, package = "fluence-fork-libp2p-mplex" }
|
||||||
libp2p-noise = { version = "0.28.0", path = "protocols/noise", optional = true, package = "fluence-fork-libp2p-noise" }
|
libp2p-noise = { version = "0.28.1", path = "protocols/noise", optional = true, package = "fluence-fork-libp2p-noise" }
|
||||||
libp2p-ping = { version = "0.26.0", path = "protocols/ping", optional = true, package = "fluence-fork-libp2p-ping" }
|
libp2p-ping = { version = "0.26.1", path = "protocols/ping", optional = true, package = "fluence-fork-libp2p-ping" }
|
||||||
libp2p-plaintext = { version = "0.26.0", path = "protocols/plaintext", optional = true, package = "fluence-fork-libp2p-plaintext" }
|
libp2p-plaintext = { version = "0.26.1", path = "protocols/plaintext", optional = true, package = "fluence-fork-libp2p-plaintext" }
|
||||||
libp2p-pnet = { version = "0.20.0", path = "protocols/pnet", optional = true, package = "fluence-fork-libp2p-pnet" }
|
libp2p-pnet = { version = "0.20.1", path = "protocols/pnet", optional = true, package = "fluence-fork-libp2p-pnet" }
|
||||||
libp2p-request-response = { version = "0.9.0", path = "protocols/request-response", optional = true, package = "fluence-fork-libp2p-request-response" }
|
libp2p-request-response = { version = "0.9.1", path = "protocols/request-response", optional = true, package = "fluence-fork-libp2p-request-response" }
|
||||||
libp2p-swarm = { version = "0.26.0", path = "swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
libp2p-uds = { version = "0.26.0", path = "transports/uds", optional = true, package = "fluence-fork-libp2p-uds" }
|
libp2p-uds = { version = "0.26.1", path = "transports/uds", optional = true, package = "fluence-fork-libp2p-uds" }
|
||||||
libp2p-wasm-ext = { version = "0.26.0", path = "transports/wasm-ext", optional = true, package = "fluence-fork-libp2p-wasm-ext" }
|
libp2p-wasm-ext = { version = "0.26.1", path = "transports/wasm-ext", optional = true, package = "fluence-fork-libp2p-wasm-ext" }
|
||||||
libp2p-yamux = { version = "0.29.0", path = "muxers/yamux", optional = true, package = "fluence-fork-libp2p-yamux" }
|
libp2p-yamux = { version = "0.29.1", path = "muxers/yamux", optional = true, package = "fluence-fork-libp2p-yamux" }
|
||||||
multiaddr = { package = "fluence-fork-parity-multiaddr", version = "0.10.0", path = "misc/multiaddr" }
|
multiaddr = { package = "fluence-fork-parity-multiaddr", version = "0.10.1", path = "misc/multiaddr" }
|
||||||
parking_lot = "0.11.0"
|
parking_lot = "0.11.0"
|
||||||
pin-project = "1.0.0"
|
pin-project = "1.0.0"
|
||||||
smallvec = "1.0"
|
smallvec = "1.0"
|
||||||
wasm-timer = "0.2.4"
|
wasm-timer = "0.2.4"
|
||||||
|
|
||||||
[target.'cfg(not(any(target_os = "emscripten", target_os = "wasi", target_os = "unknown")))'.dependencies]
|
[target.'cfg(not(any(target_os = "emscripten", target_os = "wasi", target_os = "unknown")))'.dependencies]
|
||||||
libp2p-deflate = { package = "fluence-fork-libp2p-deflate", version = "0.26.0", path = "protocols/deflate", optional = true }
|
libp2p-deflate = { package = "fluence-fork-libp2p-deflate", version = "0.26.1", path = "protocols/deflate", optional = true }
|
||||||
libp2p-dns = { package = "fluence-fork-libp2p-dns", version = "0.26.0", path = "transports/dns", optional = true }
|
libp2p-dns = { package = "fluence-fork-libp2p-dns", version = "0.26.1", path = "transports/dns", optional = true }
|
||||||
libp2p-mdns = { package = "fluence-fork-libp2p-mdns", version = "0.27.0", path = "protocols/mdns", optional = true }
|
libp2p-mdns = { package = "fluence-fork-libp2p-mdns", version = "0.27.0", path = "protocols/mdns", optional = true }
|
||||||
libp2p-tcp = { package = "fluence-fork-libp2p-tcp", version = "0.26.0", path = "transports/tcp", optional = true }
|
libp2p-tcp = { package = "fluence-fork-libp2p-tcp", version = "0.26.1", path = "transports/tcp", optional = true }
|
||||||
libp2p-websocket = { package = "fluence-fork-libp2p-websocket", version = "0.27.0", path = "transports/websocket", optional = true }
|
libp2p-websocket = { package = "fluence-fork-libp2p-websocket", version = "0.27.0", path = "transports/websocket", optional = true }
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-core"
|
name = "fluence-fork-libp2p-core"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Core traits and structs of libp2p"
|
description = "Core traits and structs of libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -23,9 +23,9 @@ futures-timer = "3"
|
|||||||
lazy_static = "1.2"
|
lazy_static = "1.2"
|
||||||
libsecp256k1 = { version = "0.3.1", optional = true }
|
libsecp256k1 = { version = "0.3.1", optional = true }
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
multiaddr = { package = "fluence-fork-parity-multiaddr", version = "0.10.0", path = "../misc/multiaddr" }
|
multiaddr = { package = "fluence-fork-parity-multiaddr", version = "0.10.1", path = "../misc/multiaddr" }
|
||||||
multihash = { version = "0.13", default-features = false, features = ["std", "multihash-impl", "identity", "sha2"] }
|
multihash = { version = "0.13", default-features = false, features = ["std", "multihash-impl", "identity", "sha2"] }
|
||||||
multistream-select = { version = "0.9.1", path = "../misc/multistream-select", package = "fluence-fork-multistream-select" }
|
multistream-select = { version = "0.9.2", path = "../misc/multistream-select", package = "fluence-fork-multistream-select" }
|
||||||
parking_lot = "0.11.0"
|
parking_lot = "0.11.0"
|
||||||
pin-project = "1.0.0"
|
pin-project = "1.0.0"
|
||||||
prost = "0.6.1"
|
prost = "0.6.1"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-core-derive"
|
name = "fluence-fork-libp2p-core-derive"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Procedural macros of libp2p-core"
|
description = "Procedural macros of libp2p-core"
|
||||||
version = "0.21.0"
|
version = "0.21.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
|
@ -6,7 +6,7 @@ description = "Implementation of the multiaddr format"
|
|||||||
homepage = "https://github.com/libp2p/rust-libp2p"
|
homepage = "https://github.com/libp2p/rust-libp2p"
|
||||||
keywords = ["multiaddr", "ipfs"]
|
keywords = ["multiaddr", "ipfs"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
version = "0.10.0"
|
version = "0.10.1"
|
||||||
|
|
||||||
[features]
|
[features]
|
||||||
default = ["url"]
|
default = ["url"]
|
||||||
|
@ -1,6 +1,5 @@
|
|||||||
use std::borrow::Cow;
|
use std::borrow::Cow;
|
||||||
use std::fmt::Debug;
|
use std::fmt::Debug;
|
||||||
use serde::export::Formatter;
|
|
||||||
use std::fmt;
|
use std::fmt;
|
||||||
|
|
||||||
/// Represents an Onion v3 address
|
/// Represents an Onion v3 address
|
||||||
@ -45,7 +44,7 @@ impl<'a> From<(&'a [u8; 35], u16)> for Onion3Addr<'a> {
|
|||||||
}
|
}
|
||||||
|
|
||||||
impl Debug for Onion3Addr<'_> {
|
impl Debug for Onion3Addr<'_> {
|
||||||
fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), fmt::Error> {
|
fn fmt(&self, f: &mut fmt::Formatter<'_>) -> Result<(), fmt::Error> {
|
||||||
f.debug_tuple("Onion3Addr")
|
f.debug_tuple("Onion3Addr")
|
||||||
.field(&format!("{:02x?}", &self.0[..]))
|
.field(&format!("{:02x?}", &self.0[..]))
|
||||||
.field(&self.1)
|
.field(&self.1)
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "fluence-fork-multistream-select"
|
name = "fluence-fork-multistream-select"
|
||||||
description = "Multistream-select negotiation protocol for libp2p"
|
description = "Multistream-select negotiation protocol for libp2p"
|
||||||
version = "0.9.1"
|
version = "0.9.2"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-mplex"
|
name = "fluence-fork-libp2p-mplex"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Mplex multiplexing protocol for libp2p"
|
description = "Mplex multiplexing protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -16,7 +16,7 @@ name = "libp2p_mplex"
|
|||||||
bytes = "0.5"
|
bytes = "0.5"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
futures_codec = "0.4.1"
|
futures_codec = "0.4.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
nohash-hasher = "0.2"
|
nohash-hasher = "0.2"
|
||||||
parking_lot = "0.11"
|
parking_lot = "0.11"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-yamux"
|
name = "fluence-fork-libp2p-yamux"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Yamux multiplexing protocol for libp2p"
|
description = "Yamux multiplexing protocol for libp2p"
|
||||||
version = "0.29.0"
|
version = "0.29.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -14,7 +14,7 @@ name = "libp2p_yamux"
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
parking_lot = "0.11"
|
parking_lot = "0.11"
|
||||||
thiserror = "1.0"
|
thiserror = "1.0"
|
||||||
yamux = "0.8.0"
|
yamux = "0.8.0"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-deflate"
|
name = "fluence-fork-libp2p-deflate"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Deflate encryption protocol for libp2p"
|
description = "Deflate encryption protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -14,7 +14,7 @@ name = "libp2p_deflate"
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
flate2 = "1.0"
|
flate2 = "1.0"
|
||||||
|
|
||||||
[dev-dependencies]
|
[dev-dependencies]
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-floodsub"
|
name = "fluence-fork-libp2p-floodsub"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Floodsub protocol for libp2p"
|
description = "Floodsub protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -16,8 +16,8 @@ name = "libp2p_floodsub"
|
|||||||
cuckoofilter = "0.5.0"
|
cuckoofilter = "0.5.0"
|
||||||
fnv = "1.0"
|
fnv = "1.0"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
libp2p-swarm = { version = "0.26.0", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
prost = "0.6.1"
|
prost = "0.6.1"
|
||||||
rand = "0.7"
|
rand = "0.7"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-gossipsub"
|
name = "fluence-fork-libp2p-gossipsub"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Gossipsub protocol for libp2p"
|
description = "Gossipsub protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Age Manning <Age@AgeManning.com>"]
|
authors = ["Age Manning <Age@AgeManning.com>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -13,8 +13,8 @@ categories = ["network-programming", "asynchronous"]
|
|||||||
name = "libp2p_gossipsub"
|
name = "libp2p_gossipsub"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
libp2p-swarm = { version = "0.26.0", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
bytes = "0.5.6"
|
bytes = "0.5.6"
|
||||||
byteorder = "1.3.4"
|
byteorder = "1.3.4"
|
||||||
fnv = "1.0.7"
|
fnv = "1.0.7"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-identify"
|
name = "fluence-fork-libp2p-identify"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Nodes identifcation protocol for libp2p"
|
description = "Nodes identifcation protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -14,8 +14,8 @@ name = "libp2p_identify"
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
libp2p-swarm = { version = "0.26.0", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
log = "0.4.1"
|
log = "0.4.1"
|
||||||
prost = "0.6.1"
|
prost = "0.6.1"
|
||||||
smallvec = "1.0"
|
smallvec = "1.0"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-kad"
|
name = "fluence-fork-libp2p-kad"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Kademlia protocol for libp2p"
|
description = "Kademlia protocol for libp2p"
|
||||||
version = "0.27.0"
|
version = "0.27.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -20,8 +20,8 @@ fnv = "1.0"
|
|||||||
futures_codec = "0.4"
|
futures_codec = "0.4"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
libp2p-swarm = { version = "0.26.0", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
prost = "0.6.1"
|
prost = "0.6.1"
|
||||||
rand = "0.7.2"
|
rand = "0.7.2"
|
||||||
sha2 = "0.9.1"
|
sha2 = "0.9.1"
|
||||||
|
@ -589,6 +589,14 @@ where
|
|||||||
self.queries.add_iter_closest(target.clone(), peers, inner)
|
self.queries.add_iter_closest(target.clone(), peers, inner)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Returns closest peers to the given key; takes peers from local routing table
|
||||||
|
pub fn local_closest_peers<K>(&mut self, key: K) -> Vec<WeightedPeer>
|
||||||
|
where
|
||||||
|
K: Into<kbucket::Key<K>> + Into<Vec<u8>> + Clone {
|
||||||
|
let target: kbucket::Key<K> = key.into();
|
||||||
|
Self::closest_keys(&mut self.kbuckets, &target).collect()
|
||||||
|
}
|
||||||
|
|
||||||
/// Performs a lookup for a record in the DHT.
|
/// Performs a lookup for a record in the DHT.
|
||||||
///
|
///
|
||||||
/// The result of this operation is delivered in a
|
/// The result of this operation is delivered in a
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "fluence-fork-libp2p-mdns"
|
name = "fluence-fork-libp2p-mdns"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
version = "0.27.0"
|
version = "0.27.1"
|
||||||
description = "Implementation of the libp2p mDNS discovery method"
|
description = "Implementation of the libp2p mDNS discovery method"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
@ -19,8 +19,8 @@ dns-parser = "0.8.0"
|
|||||||
futures = "0.3.8"
|
futures = "0.3.8"
|
||||||
if-watch = "0.1.6"
|
if-watch = "0.1.6"
|
||||||
lazy_static = "1.4.0"
|
lazy_static = "1.4.0"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
libp2p-swarm = { version = "0.26.0", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
log = "0.4.11"
|
log = "0.4.11"
|
||||||
rand = "0.7.3"
|
rand = "0.7.3"
|
||||||
smallvec = "1.5.0"
|
smallvec = "1.5.0"
|
||||||
|
@ -1,7 +1,7 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "fluence-fork-libp2p-noise"
|
name = "fluence-fork-libp2p-noise"
|
||||||
description = "Cryptographic handshake protocol using the noise framework."
|
description = "Cryptographic handshake protocol using the noise framework."
|
||||||
version = "0.28.0"
|
version = "0.28.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -15,7 +15,7 @@ bytes = "0.5"
|
|||||||
curve25519-dalek = "3.0.0"
|
curve25519-dalek = "3.0.0"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
lazy_static = "1.2"
|
lazy_static = "1.2"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
prost = "0.6.1"
|
prost = "0.6.1"
|
||||||
rand = "0.7.2"
|
rand = "0.7.2"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-ping"
|
name = "fluence-fork-libp2p-ping"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Ping protocol for libp2p"
|
description = "Ping protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -14,8 +14,8 @@ name = "libp2p_ping"
|
|||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
libp2p-swarm = { version = "0.26.0", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
log = "0.4.1"
|
log = "0.4.1"
|
||||||
rand = "0.7.2"
|
rand = "0.7.2"
|
||||||
void = "1.0"
|
void = "1.0"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-plaintext"
|
name = "fluence-fork-libp2p-plaintext"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Plaintext encryption dummy protocol for libp2p"
|
description = "Plaintext encryption dummy protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -16,7 +16,7 @@ name = "libp2p_plaintext"
|
|||||||
bytes = "0.5"
|
bytes = "0.5"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
futures_codec = "0.4.0"
|
futures_codec = "0.4.0"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4.8"
|
log = "0.4.8"
|
||||||
prost = "0.6.1"
|
prost = "0.6.1"
|
||||||
unsigned-varint = { version = "0.5.1", features = ["futures-codec"] }
|
unsigned-varint = { version = "0.5.1", features = ["futures-codec"] }
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-pnet"
|
name = "fluence-fork-libp2p-pnet"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Private swarm support for libp2p"
|
description = "Private swarm support for libp2p"
|
||||||
version = "0.20.0"
|
version = "0.20.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-request-response"
|
name = "fluence-fork-libp2p-request-response"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Generic Request/Response Protocols"
|
description = "Generic Request/Response Protocols"
|
||||||
version = "0.9.0"
|
version = "0.9.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -16,8 +16,8 @@ name = "libp2p_request_response"
|
|||||||
async-trait = "0.1"
|
async-trait = "0.1"
|
||||||
bytes = "0.5.6"
|
bytes = "0.5.6"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
libp2p-swarm = { version = "0.26.0", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
libp2p-swarm = { version = "0.26.1", path = "../../swarm", package = "fluence-fork-libp2p-swarm" }
|
||||||
log = "0.4.11"
|
log = "0.4.11"
|
||||||
lru = "0.6"
|
lru = "0.6"
|
||||||
minicbor = { version = "0.7", features = ["std", "derive"] }
|
minicbor = { version = "0.7", features = ["std", "derive"] }
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-secio"
|
name = "fluence-fork-libp2p-secio"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Secio encryption protocol for libp2p"
|
description = "Secio encryption protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -22,7 +22,7 @@ ctr = "0.3"
|
|||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
hmac = "0.9.0"
|
hmac = "0.9.0"
|
||||||
lazy_static = "1.2.0"
|
lazy_static = "1.2.0"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4.6"
|
log = "0.4.6"
|
||||||
prost = "0.6.1"
|
prost = "0.6.1"
|
||||||
pin-project = "1.0.0"
|
pin-project = "1.0.0"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-swarm"
|
name = "fluence-fork-libp2p-swarm"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "The libp2p swarm"
|
description = "The libp2p swarm"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -15,7 +15,7 @@ name = "libp2p_swarm"
|
|||||||
[dependencies]
|
[dependencies]
|
||||||
either = "1.6.0"
|
either = "1.6.0"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4"
|
log = "0.4"
|
||||||
rand = "0.7"
|
rand = "0.7"
|
||||||
smallvec = "1.0"
|
smallvec = "1.0"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-dns"
|
name = "fluence-fork-libp2p-dns"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "DNS transport implementation for libp2p"
|
description = "DNS transport implementation for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -13,7 +13,7 @@ categories = ["network-programming", "asynchronous"]
|
|||||||
name = "libp2p_dns"
|
name = "libp2p_dns"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4.1"
|
log = "0.4.1"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
|
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-tcp"
|
name = "fluence-fork-libp2p-tcp"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "TCP/IP transport protocol for libp2p"
|
description = "TCP/IP transport protocol for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -18,7 +18,7 @@ futures = "0.3.1"
|
|||||||
futures-timer = "3.0"
|
futures-timer = "3.0"
|
||||||
if-addrs = "0.6.4"
|
if-addrs = "0.6.4"
|
||||||
ipnet = "2.0.0"
|
ipnet = "2.0.0"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4.1"
|
log = "0.4.1"
|
||||||
socket2 = { version = "0.3.12" }
|
socket2 = { version = "0.3.12" }
|
||||||
tokio = { version = "0.3", default-features = false, features = ["net"], optional = true }
|
tokio = { version = "0.3", default-features = false, features = ["net"], optional = true }
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-uds"
|
name = "fluence-fork-libp2p-uds"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Unix domain sockets transport for libp2p"
|
description = "Unix domain sockets transport for libp2p"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -15,7 +15,7 @@ name = "libp2p_uds"
|
|||||||
|
|
||||||
[target.'cfg(all(unix, not(target_os = "emscripten")))'.dependencies]
|
[target.'cfg(all(unix, not(target_os = "emscripten")))'.dependencies]
|
||||||
async-std = { version = "1.6.2", optional = true }
|
async-std = { version = "1.6.2", optional = true }
|
||||||
libp2p-core = { package = "fluence-fork-libp2p-core", version = "0.26.0", path = "../../core" }
|
libp2p-core = { package = "fluence-fork-libp2p-core", version = "0.26.1", path = "../../core" }
|
||||||
log = "0.4.1"
|
log = "0.4.1"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
tokio = { version = "0.3", default-features = false, features = ["net"], optional = true }
|
tokio = { version = "0.3", default-features = false, features = ["net"], optional = true }
|
||||||
|
@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "fluence-fork-libp2p-wasm-ext"
|
name = "fluence-fork-libp2p-wasm-ext"
|
||||||
version = "0.26.0"
|
version = "0.26.1"
|
||||||
authors = ["Pierre Krieger <pierre.krieger1708@gmail.com>"]
|
authors = ["Pierre Krieger <pierre.krieger1708@gmail.com>"]
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "Allows passing in an external transport in a WASM environment"
|
description = "Allows passing in an external transport in a WASM environment"
|
||||||
@ -15,7 +15,7 @@ name = "libp2p_wasm_ext"
|
|||||||
[dependencies]
|
[dependencies]
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
js-sys = "0.3.19"
|
js-sys = "0.3.19"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
parity-send-wrapper = "0.1.0"
|
parity-send-wrapper = "0.1.0"
|
||||||
wasm-bindgen = "0.2.42"
|
wasm-bindgen = "0.2.42"
|
||||||
wasm-bindgen-futures = "0.4.4"
|
wasm-bindgen-futures = "0.4.4"
|
||||||
|
@ -2,7 +2,7 @@
|
|||||||
name = "fluence-fork-libp2p-websocket"
|
name = "fluence-fork-libp2p-websocket"
|
||||||
edition = "2018"
|
edition = "2018"
|
||||||
description = "WebSocket transport for libp2p"
|
description = "WebSocket transport for libp2p"
|
||||||
version = "0.27.0"
|
version = "0.27.1"
|
||||||
authors = ["Parity Technologies <admin@parity.io>"]
|
authors = ["Parity Technologies <admin@parity.io>"]
|
||||||
license = "MIT"
|
license = "MIT"
|
||||||
repository = "https://github.com/libp2p/rust-libp2p"
|
repository = "https://github.com/libp2p/rust-libp2p"
|
||||||
@ -16,7 +16,7 @@ name = "libp2p_websocket"
|
|||||||
async-tls = "0.11.0"
|
async-tls = "0.11.0"
|
||||||
either = "1.5.3"
|
either = "1.5.3"
|
||||||
futures = "0.3.1"
|
futures = "0.3.1"
|
||||||
libp2p-core = { version = "0.26.0", path = "../../core", package = "fluence-fork-libp2p-core" }
|
libp2p-core = { version = "0.26.1", path = "../../core", package = "fluence-fork-libp2p-core" }
|
||||||
log = "0.4.8"
|
log = "0.4.8"
|
||||||
quicksink = "0.1"
|
quicksink = "0.1"
|
||||||
rustls = "0.19.0"
|
rustls = "0.19.0"
|
||||||
|
Loading…
x
Reference in New Issue
Block a user