Uses of Class
org.drasyl.identity.DrasylAddress
Package
Description
netty
Channel
for the drasyl overlay
network.Chord-based distributed hash table.
Different methods to discover peers.
CYCLON membership management.
Logs channel events/messages for monitoring purpose.
Information about peers.
Handlers used to communicate with remote nodes.
Discovery/Routing of peers on the internet.
The protocol used for communication with remote peers.
Contains classes to manage the
Identity
of the drasyl node.Contains
DrasylNode
.Describes
DrasylNode
s as finite state machines.Contains events that inform about various states of the
DrasylNode
(started, stopped, etc.) or overlay network events (messages, peer discovery, etc.)-
Uses of DrasylAddress in org.drasyl.channel
Modifier and TypeMethodDescriptionDrasylServerChannel.getChannel
(DrasylAddress peer) protected DrasylChannel
DrasylServerChannel.newDrasylChannel
(DrasylAddress peer) io.netty.channel.ChannelFuture
DrasylServerChannel.serve
(DrasylAddress peer) ModifierConstructorDescriptionOverlayAddressedMessage
(M message, DrasylAddress recipient) OverlayAddressedMessage
(M message, DrasylAddress recipient, DrasylAddress sender) -
Uses of DrasylAddress in org.drasyl.handler.dht.chord
Modifier and TypeMethodDescriptionChordFingerTable.get
(int i) abstract DrasylAddress
ChordResponse.getAddress()
abstract DrasylAddress
ChordLookup.getContact()
ChordFingerTable.getSuccessor()
Modifier and TypeMethodDescriptionio.netty.util.concurrent.Future<DrasylAddress>
LocalChordNode.findClosestFingerPreceding
(long id) io.netty.util.concurrent.Future<DrasylAddress>
RemoteChordNode.findClosestFingerPreceding
(long id) Find the closest finger preceding.io.netty.util.concurrent.Future<DrasylAddress>
LocalChordNode.findSuccessor
(long id) io.netty.util.concurrent.Future<DrasylAddress>
RemoteChordNode.findSuccessor
(long id) Find successor forid
.io.netty.util.concurrent.Future<DrasylAddress>
LocalChordNode.getPredecessor()
io.netty.util.concurrent.Future<DrasylAddress>
RemoteChordNode.getPredecessor()
Returns the predecessor.io.netty.util.concurrent.Future<DrasylAddress>
LocalChordNode.getSuccessor()
io.netty.util.concurrent.Future<DrasylAddress>
RemoteChordNode.getSuccessor()
Returns the successor.Modifier and TypeMethodDescriptionio.netty.util.concurrent.Future<Void>
LocalChordNode.join
(DrasylAddress contact) Join circle by contactingcontact
.static ChordLookup
ChordLookup.of
(DrasylAddress contact, long id) static ChordLookup
ChordLookup.of
(DrasylAddress contact, long id, boolean doStableCheck) static ChordResponse
ChordResponse.of
(long id, DrasylAddress address) void
ChordFingerTable.removePeer
(DrasylAddress value) boolean
ChordFingerTable.updateIthFinger
(int i, DrasylAddress value) Updates thei
th finger to point atvalue
.ModifierConstructorDescriptionChordFingerTable
(DrasylAddress localAddress) ChordJoinHandler
(DrasylAddress contact, LocalChordNode localNode) LocalChordNode
(DrasylAddress localAddress, ChordFingerTable fingerTable, RmiClientHandler client) LocalChordNode
(DrasylAddress address, RmiClientHandler client) -
Uses of DrasylAddress in org.drasyl.handler.discovery
Modifier and TypeMethodDescriptionstatic AddPathAndChildrenEvent
AddPathAndChildrenEvent.of
(DrasylAddress address, InetSocketAddress inetAddress, Object path) static AddPathAndSuperPeerEvent
AddPathAndSuperPeerEvent.of
(DrasylAddress address, InetSocketAddress inetAddress, Object path, long rtt) static AddPathEvent
AddPathEvent.of
(DrasylAddress address, InetSocketAddress inetAddress, Object path) static AddPathEvent
AddPathEvent.of
(DrasylAddress publicKey, InetSocketAddress inetAddress, Object path, long rtt) static PathRttEvent
PathRttEvent.of
(DrasylAddress publicKey, InetSocketAddress inetAddress, Object path, long rtt) static RemoveChildrenAndPathEvent
RemoveChildrenAndPathEvent.of
(DrasylAddress address, Object path) static RemovePathEvent
RemovePathEvent.of
(DrasylAddress address, Object path) static RemoveSuperPeerAndPathEvent
RemoveSuperPeerAndPathEvent.of
(DrasylAddress address, Object path) -
Uses of DrasylAddress in org.drasyl.handler.membership.cyclon
Modifier and TypeMethodDescriptionstatic CyclonNeighbor
CyclonNeighbor.of
(DrasylAddress address) static CyclonNeighbor
CyclonNeighbor.of
(DrasylAddress address, int age) Modifier and TypeMethodDescriptionstatic CyclonView
CyclonView.ofKeys
(int capacity, Collection<DrasylAddress> neighbors) -
Uses of DrasylAddress in org.drasyl.handler.monitoring
Modifier and TypeFieldDescriptionprotected final Map<DrasylAddress,
InetSocketAddress> TopologyHandler.childrenPeers
protected final Map<DrasylAddress,
InetSocketAddress> TopologyHandler.superPeers
Modifier and TypeMethodDescriptionTopologyHandler.Topology.childrenPeers()
TopologyHandler.Topology.superPeers()
ModifierConstructorDescriptionTopology
(DrasylAddress address, Map<DrasylAddress, InetSocketAddress> superPeers, Map<DrasylAddress, InetSocketAddress> childrenPeers) ModifierConstructorDescriptionTopology
(DrasylAddress address, Map<DrasylAddress, InetSocketAddress> superPeers, Map<DrasylAddress, InetSocketAddress> childrenPeers) protected
TopologyHandler
(Map<DrasylAddress, InetSocketAddress> superPeers, Map<DrasylAddress, InetSocketAddress> childrenPeers) -
Uses of DrasylAddress in org.drasyl.handler.peers
-
Uses of DrasylAddress in org.drasyl.handler.pubsub
ModifierConstructorDescriptionPubSubPublishHandler
(Duration publishTimeout, DrasylAddress broker) PubSubPublishHandler
(DrasylAddress broker) PubSubSubscribeHandler
(Duration subscribeTimeout, DrasylAddress broker) PubSubSubscribeHandler
(DrasylAddress broker) -
Uses of DrasylAddress in org.drasyl.handler.remote
Modifier and TypeMethodDescriptionPeersManager.setDefaultPeer
(DrasylAddress newDefaultPeerKey) PeersManager.setDefaultPeerIfUnset
(DrasylAddress newDefaultPeerKey) PeersManager.unsetDefaultPeer()
Modifier and TypeMethodDescriptionvoid
PeersManager.acknowledgementMessageReceived
(DrasylAddress peerKey, PeersManager.PathId id) void
PeersManager.acknowledgementMessageReceived
(DrasylAddress peerKey, PeersManager.PathId id, int rtt) boolean
PeersManager.addChildrenPath
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint) boolean
PeersManager.addChildrenPath
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint, int rtt) boolean
PeersManager.addSuperPeerPath
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint, int rtt) void
PeersManager.applicationMessageReceived
(DrasylAddress peerKey) void
PeersManager.applicationMessageSent
(DrasylAddress peerKey) boolean
PeersManager.hasApplicationTraffic
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey) boolean
PeersManager.hasPath
(DrasylAddress peerKey) boolean
PeersManager.hasPath
(DrasylAddress peerKey, PeersManager.PathId id) void
PeersManager.helloMessageReceived
(DrasylAddress peerKey, PeersManager.PathId id) void
PeersManager.helloMessageSent
(DrasylAddress peerKey, PeersManager.PathId id) boolean
PeersManager.isReachable
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id) boolean
PeersManager.isStale
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id) boolean
PeersManager.removeChildrenPath
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id) boolean
PeersManager.removeSuperPeerPath
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id) PeersManager.resolve
(DrasylAddress peerKey) PeersManager.resolveInetAddress
(DrasylAddress peerKey, PeersManager.PathId id) int
PeersManager.rtt
(DrasylAddress peerKey, PeersManager.PathId id) PeersManager.setDefaultPeer
(DrasylAddress newDefaultPeerKey) PeersManager.setDefaultPeerIfUnset
(DrasylAddress newDefaultPeerKey) boolean
PeersManager.tryAddChildrenPath
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress peerKey, PeersManager.PathId id, InetSocketAddress endpoint) ModifierConstructorDescriptionStaticRoutesHandler
(Map<DrasylAddress, InetSocketAddress> staticRoutes) -
Uses of DrasylAddress in org.drasyl.handler.remote.internet
Modifier and TypeFieldDescriptionprotected final Map<DrasylAddress,
InternetDiscoverySuperPeerHandler.ChildrenPeer> InternetDiscoverySuperPeerHandler.childrenPeers
Modifier and TypeMethodDescriptionprotected void
InternetDiscoveryChildrenHandler.writeHelloMessage
(io.netty.channel.ChannelHandlerContext ctx, DrasylAddress publicKey, InetSocketAddress inetAddress, Set<InetSocketAddress> privateInetAddresses) Make sure to callChannel.flush()
by your own! -
Uses of DrasylAddress in org.drasyl.handler.remote.protocol
Modifier and TypeMethodDescriptionabstract DrasylAddress
UniteMessage.getAddress()
Returns the public key of the peer.FullReadMessage.getRecipient()
Returns theIdentityPublicKey
of the message recipient.abstract DrasylAddress
HelloMessage.getRecipient()
Returns theIdentityPublicKey
of the message recipient.abstract DrasylAddress
PublicHeader.getRecipient()
RemoteMessage.getRecipient()
abstract DrasylAddress
UnarmedProtocolMessage.getRecipient()
abstract DrasylAddress
PublicHeader.getSender()
RemoteMessage.getSender()
Modifier and TypeMethodDescriptionstatic AcknowledgementMessage
AcknowledgementMessage.of
(int networkId, DrasylAddress recipient, IdentityPublicKey sender, ProofOfWork proofOfWork, long time) static AcknowledgementMessage
AcknowledgementMessage.of
(HopCount hopCount, boolean isArmed, int networkId, Nonce nonce, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork, long time) Creates new acknowledgement message.static ApplicationMessage
ApplicationMessage.of
(HopCount hopCount, boolean isArmed, int networkId, Nonce nonce, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork, io.netty.buffer.ByteBuf payload) Creates new application message.static ArmedProtocolMessage
ArmedProtocolMessage.of
(Nonce nonce, HopCount hopCount, int networkId, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork, io.netty.buffer.ByteBuf bytes) Creates an armed message.static HelloMessage
HelloMessage.of
(int networkId, DrasylAddress recipient, IdentityPublicKey sender, ProofOfWork proofOfWork) Creates a newHelloMessage
.static HelloMessage
HelloMessage.of
(int networkId, DrasylAddress recipient, IdentityPublicKey sender, ProofOfWork proofOfWork, long time, long childrenTime, IdentitySecretKey secretKey, Set<InetSocketAddress> endpoints) Creates a newHelloMessage
.static HelloMessage
HelloMessage.of
(int networkId, DrasylAddress recipient, IdentityPublicKey sender, ProofOfWork proofOfWork, long childrenTime, IdentitySecretKey secretKey, Set<InetSocketAddress> endpoints) Creates a newHelloMessage
.static HelloMessage
HelloMessage.of
(HopCount hopCount, boolean isArmed, int networkId, Nonce nonce, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork, long time, long childrenTime, IdentitySecretKey secretKey, Set<InetSocketAddress> endpoints) Creates newHelloMessage
.static HelloMessage
HelloMessage.of
(HopCount hopCount, boolean isArmed, int networkId, Nonce nonce, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork, long time, long childrenTime, ImmutableByteArray signature, Set<InetSocketAddress> endpoints) Creates a newHelloMessage
.static PublicHeader
PublicHeader.of
(HopCount hopCount, boolean isArmed, int networkId, Nonce nonce, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork) static UnarmedProtocolMessage
UnarmedProtocolMessage.of
(HopCount hopCount, boolean isArmed, int networkId, Nonce nonce, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork, io.netty.buffer.ByteBuf bytes) Creates an unarmed message.static UniteMessage
UniteMessage.of
(int networkId, DrasylAddress recipient, IdentityPublicKey sender, ProofOfWork proofOfWork, DrasylAddress address, Set<InetSocketAddress> endpoints) static UniteMessage
UniteMessage.of
(HopCount hopCount, boolean isArmed, int networkId, Nonce nonce, DrasylAddress recipient, DrasylAddress sender, ProofOfWork proofOfWork, DrasylAddress address, Set<InetSocketAddress> endpoints) Creates new unit message. -
Uses of DrasylAddress in org.drasyl.identity
Modifier and TypeClassDescriptionclass
This class models an ed25519 public key that is used as node's unique overlay address.Modifier and TypeMethodDescriptionstatic ProofOfWork
ProofOfWork.generateProofOfWork
(DrasylAddress address, byte difficulty) static byte
ProofOfWork.getDifficulty
(ProofOfWork proofOfWork, DrasylAddress publicKey) boolean
ProofOfWork.isValid
(DrasylAddress address, byte difficulty) Checks if the current proof of work is valid for given public key and difficulty. -
Uses of DrasylAddress in org.drasyl.node
Modifier and TypeMethodDescriptionabstract Map<DrasylAddress,
InetSocketAddress> DrasylConfig.getRemoteStaticRoutes()
static Map<DrasylAddress,
InetSocketAddress> DrasylConfig.getStaticRoutes
(com.typesafe.config.Config config, String path) Modifier and TypeMethodDescriptionCompletionStage<io.netty.channel.Channel>
DrasylNode.resolve
(DrasylAddress address) Creates a future containing aChannel
for communication withaddress
.DrasylNode.send
(DrasylAddress recipient, Object payload) Sends the content ofpayload
to the identityrecipient
.Modifier and TypeMethodDescriptionabstract DrasylConfig.Builder
DrasylConfig.Builder.remoteStaticRoutes
(Map<DrasylAddress, InetSocketAddress> remoteStaticRoutes) -
Uses of DrasylAddress in org.drasyl.node.behaviour
Modifier and TypeMethodDescriptionBehavior.BehaviorBuilder.onMessageEquals
(DrasylAddress sender, M payload, Supplier<Behavior> handler) Add a new case to the event handling matching events of typeMessageEvent
with equalMessageEvent.getPayload()
.Modifier and TypeMethodDescriptionBehavior.BehaviorBuilder.messageAdapter
(Class<M> messageType, BiFunction<DrasylAddress, M, Object> adapter) Add a new case to the event handling matching events of typeMessageEvent
withMessageEvent.getPayload()
matchingmessageType
.Behavior.BehaviorBuilder.onAnyMessage
(BiFunction<DrasylAddress, M, Behavior> handler) Add a new case to the event handling matching anyMessageEvent
.Behavior.BehaviorBuilder.onMessage
(Class<M> messageType, BiFunction<DrasylAddress, M, Behavior> handler) Add a new case to the event handling matching events of typeMessageEvent
withMessageEvent.getPayload()
matchingmessageType
.Behavior.BehaviorBuilder.onMessage
(Class<M> messageType, BiPredicate<DrasylAddress, M> test, BiFunction<DrasylAddress, M, Behavior> handler) Add a new predicated case to the event handling matching events of typeMessageEvent
withMessageEvent.getPayload()
matchingmessageType
.Behavior.BehaviorBuilder.onMessage
(Class<M> messageType, BiPredicate<DrasylAddress, M> test, BiFunction<DrasylAddress, M, Behavior> handler) Add a new predicated case to the event handling matching events of typeMessageEvent
withMessageEvent.getPayload()
matchingmessageType
. -
Uses of DrasylAddress in org.drasyl.node.event
Modifier and TypeMethodDescriptionabstract DrasylAddress
Peer.getAddress()
Returns the peer's address.abstract DrasylAddress
MessageEvent.getSender()
Returns the message's sender.Modifier and TypeMethodDescriptionstatic MessageEvent
MessageEvent.of
(DrasylAddress sender, Object payload) Creates a newMessageEvent
static Peer
Peer.of
(DrasylAddress address) -
Uses of DrasylAddress in org.drasyl.serialization