de.cgrotz.kademlia

Class Kademlia

java.lang.Object

de.cgrotz.kademlia.Kademlia

public class Kademlia
extends Object

Created by Christoph on 21.09.2016.

Field Summary

Fields

Modifier and Type	Field and Description
protected KademliaClient	client
protected Configuration	config
protected Node	localNode
protected LocalStorage	localStorage
protected RoutingTable	routingTable
protected List<KademliaServer>	servers

Constructor Summary

Constructors

Constructor and Description
Kademlia(Configuration config)
Kademlia(Configuration config, LocalStorage localStorage)
Kademlia(Key nodeId)
Kademlia(Key nodeId, String listeners)
Kademlia(Key nodeId, String listeners, LocalStorage localStorage)

Method Summary

Modifier and Type	Method and Description
void	addEventListener(String registrationId, java.util.function.Consumer<Event> eventConsumer)
void	bootstrap(Node bootstrapNode)
void	close()
String	get(Key key) Retrieve the Value associated with the Key
void	get(Key key, java.util.function.Consumer<ValueReply> valueReplyConsumer)
Node	getLocalNode()
RoutingTable	getRoutingTable()
void	put(Key key, String value) Put or Update the value in the DHT
void	refreshBuckets()
void	removeEventListener(String registrationId)
void	republishKeys() Execute key republishing Iterate over all keys that weren't updated within the last hour and republish to the other k-nodes that are closest to the associated keys

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

routingTable

protected final RoutingTable routingTable

client

protected final KademliaClient client

servers

protected final List<KademliaServer> servers

localStorage

protected final LocalStorage localStorage

localNode

protected final Node localNode

config

protected final Configuration config

Constructor Detail

Kademlia

public Kademlia(Key nodeId)

Kademlia

public Kademlia(Key nodeId,
                String listeners)

Kademlia

public Kademlia(Key nodeId,
                String listeners,
                LocalStorage localStorage)

Kademlia

public Kademlia(Configuration config)

Kademlia

public Kademlia(Configuration config,
                LocalStorage localStorage)

Method Detail

bootstrap

public void bootstrap(Node bootstrapNode)

put

public void put(Key key,
                String value)

Put or Update the value in the DHT

Parameters:

key -

value -

get

public String get(Key key)

Retrieve the Value associated with the Key

Parameters:

key -

Returns:

get

public void get(Key key,
                java.util.function.Consumer<ValueReply> valueReplyConsumer)

republishKeys

public void republishKeys()

Execute key republishing Iterate over all keys that weren't updated within the last hour and republish to the other k-nodes that are closest to the associated keys

refreshBuckets

public void refreshBuckets()

getRoutingTable

public RoutingTable getRoutingTable()

getLocalNode

public Node getLocalNode()

close

public void close()

addEventListener

public void addEventListener(String registrationId,
                             java.util.function.Consumer<Event> eventConsumer)

removeEventListener

public void removeEventListener(String registrationId)