public class Neighbors
extends java.lang.Object
Constructor and Description |
---|
Neighbors(java.util.concurrent.ScheduledExecutorService scheduler,
java.util.function.Supplier<java.util.Collection<java.net.InetSocketAddress>> entranceSupplier,
java.util.function.Function<java.net.InetSocketAddress,java.lang.Boolean> ping,
byte[] encodedConfigData) |
Modifier and Type | Method and Description |
---|---|
void |
add(NetworkID nid) |
void |
addAll(java.util.Collection<NetworkID> nids) |
byte[] |
encode() |
java.util.Collection<java.net.InetSocketAddress> |
getInetSocketAddresses() |
DHTAddress |
getLocalDHTAddress() |
java.util.Collection<NetworkID> |
getNetworkIDs() |
void |
remove(java.net.InetSocketAddress inetSocketAddress) |
void |
removeAll(java.util.Collection<java.net.InetSocketAddress> inetSocketAddresses) |
java.util.Collection<java.net.InetSocketAddress> |
search() |
java.util.Collection<NetworkID> |
search(DHTAddress searchFor,
int limit) |
java.util.Collection<NetworkID> |
searchNode(DHTAddress searchFor,
NetworkSearch searcher,
java.util.Collection<NetworkID> base,
java.util.function.Supplier<java.util.Collection<java.net.InetSocketAddress>> entranceAddressesSupplier,
int anticipantion,
int concurrencyLevel) |
java.util.Collection<java.net.InetSocketAddress> |
searchResource(DHTAddress searchFor,
NetworkSearch searcher,
java.util.function.Supplier<java.util.Collection<java.net.InetSocketAddress>> entranceAddressesSupplier,
java.util.Collection<NetworkID> base,
int anticipantion,
int concurrencyLevel) |
int |
size() |
public Neighbors(java.util.concurrent.ScheduledExecutorService scheduler, java.util.function.Supplier<java.util.Collection<java.net.InetSocketAddress>> entranceSupplier, java.util.function.Function<java.net.InetSocketAddress,java.lang.Boolean> ping, byte[] encodedConfigData)
public byte[] encode()
public int size()
public DHTAddress getLocalDHTAddress()
public java.util.Collection<java.net.InetSocketAddress> getInetSocketAddresses()
public java.util.Collection<NetworkID> getNetworkIDs()
public void add(NetworkID nid)
public void addAll(java.util.Collection<NetworkID> nids)
public void remove(java.net.InetSocketAddress inetSocketAddress)
public void removeAll(java.util.Collection<java.net.InetSocketAddress> inetSocketAddresses)
public java.util.Collection<java.net.InetSocketAddress> search()
public java.util.Collection<NetworkID> search(DHTAddress searchFor, int limit)
public java.util.Collection<NetworkID> searchNode(DHTAddress searchFor, NetworkSearch searcher, java.util.Collection<NetworkID> base, java.util.function.Supplier<java.util.Collection<java.net.InetSocketAddress>> entranceAddressesSupplier, int anticipantion, int concurrencyLevel)
public java.util.Collection<java.net.InetSocketAddress> searchResource(DHTAddress searchFor, NetworkSearch searcher, java.util.function.Supplier<java.util.Collection<java.net.InetSocketAddress>> entranceAddressesSupplier, java.util.Collection<NetworkID> base, int anticipantion, int concurrencyLevel)