All Classes and Interfaces
Class
Description
Skeleton handler that arms (encrypt) outbound and disarms (decrypt) inbound messages.
This object represents a session key agreement between two nodes.
This class represents an identifier for an
Agreement between to nodes.Utility to colorize and style Strings with ANSI escape sequences.
Utility class for operations on arrays.
The behavior of an node defines how it reacts to the events that it receives.
Immutable builder for creating
Behavior by chaining event handlers.Describes a
DrasylNode as a finite state machine.Factories for
Behavior.A bloom filter is a probabilistic data structure that can quickly and efficiently check whether
an element is included in a set.
This Serializer (de)serializes
Boolean objects.This Serializer (de)serializes byte arrays (just returns the byte array unchanged/uncopied).
This Serializer (de)serializes
Byte objects.Encodes
ByteBufs to GoBackNArqDatas and vice versa.Encodes
ByteBufs to StopAndWaitArqDatas and vice versa.Utility class for operations on bytes.
Signals that the path to the remote peer has been changed from direct to relayed or vice versa.
(Transport implementors only) an internal data structure used by
JavaDrasylChannel to store
its pending inbound read requests.(Transport implementors only) an internal data structure used by
JavaDrasylChannel to store
its pending inbound read requests.This Serializer (de)serializes
Character objects.Exceptions related to the Chord protocol.
Chord routing table.
This handler performs some housekeeping tasks keeping the Chord circle stable.
Joins the Chord circle or will close the
Channel.Triggers a lookup in the Chord circle to find the closest node for given
id.This handler performs a lookup in the Chord table once an outbound
ChordLookup message is
written to the channel.Reply sent in response to
ChordLookup including the closest node for a given id.Utility class for Chord-related operations.
This class wraps an object of type
T and serves as a write many read many memory.This exception is thrown when a SEND CALL is performed on an already opened connection.
This exception is thrown when a OPEN call on an already opened connection is called.
This
ChannelInitializer create a channel providing reliable and ordered delivery of bytes
between hosts.Signals that the connection is closing.
This exception is thrown when a connection is closing.
This exception is thrown when a
ChannelOutboundHandler.write(ChannelHandlerContext, Object, ChannelPromise) call,
ChannelOutboundHandler.read(ChannelHandlerContext) call,
ConnectionHandler.userCallStatus() call,
ChannelOutboundHandler.close(ChannelHandlerContext, ChannelPromise) call
is performed on a closed connection.Events emitted by
ConnectionHandler.Exceptions thrown by
ConnectionHandler.This handler provides reliable and ordered delivery of bytes between hosts.
Signals that the handshake was completed successfully.
This exception is thrown, when the remote peer refuses to establish a connection with us.
This exception is thrown when a connection is aborted.
A special
BloomFilter that allows you to remove elements.Util class that provides cryptography functions for drasyl.
A CryptoException is thrown by
Crypto when errors occur.Utility to write to a CSV file.
Encodes
CyclonMessage messages to ByteBufs and vice versa.Interface to denote messages used by CYCLON.
A CYCLON neighbor.
Requests a CYCLON shuffle.
Response of a CYCLON shuffle request.
Initiates the "Enhanced Shuffling" algorithm of CYCLON.
Waits for
CyclonShuffleRequests sent by CyclonShufflingClientHandler.Local peer's (partial) view of the network.
This class is responsible for storing the groups plugin options.
This exception signals an error occurred during execution in
DatabaseAdapter
implementations.This handler denies any (de)serialization and can be used to disable existing serializers.
Helper class for resolving hostnames to IP addresses.
This Serializer (de)serializes
Double objects.Models the address to a peer in the overlay.
This class represents the configuration for a
DrasylNode.An
Exception which is thrown by DrasylConfig.All checked exceptions in drasyl inherit from this exception class.
Represents a node in the drasyl Overlay Network.
Initialize child
JavaDrasylChannels used by DrasylNode.Initialize the
RustDrasylServerChannel used by DrasylNode.Holds parent and child
EventLoops that are shared across all
DrasylNodes.This interface is implemented by all drasyl plugins.
This class loads and binds the JNA
Sodium.Simple wrapper class that make native class easier.
Utility class for operations on
Durations.Describes an Event that provides the application with information about the local node, other
peers, connections or incoming messages.
This utility class can be used to monitor the number of pending tasks of
EventLoops.Utility class for operations on
EventLoopGroups.An implementation of
DrasylNode that provides distinct methods for handling various
Event types.A
Queue that evicts head elements to ensure that the queue will not exceed its capacity
when new elements are enqueued.A
Map that expires entries based on oldest age (when maximum size has been exceeded),
write time, or last access time.A
Set that expires elements based on oldest age (when maximum size has been exceeded) or
writeThis handler listens to files in a specific path and will then fire specific channel event.
This Serializer (de)serializes
Float objects.This utility class lat you chain up
Futures.Utility class for future-related operations.
Ack message of the Go-Back-N ARQ protocol.
Encodes
GoBackNArqMessages to ByteBufs and vice versa.Data message of the Go-Back-N ARQ protocol.
Message of the Go-Back-N ARQ protocol.
Performs the Go-Back-N ARQ receiver protocol.
Performs the Go-Back-N ARQ sender protocol.
A simple POJO that models a group.
Class is used to model the state of a group.
An event that is related to a
Group.An event that signals that this node has successfully joined a group.
An event that signals, that a joining a specific group has failed.
This message is sent by the groups server to the client when the join to a group was not
successful.
Specifies the reason of the
GroupJoinFailedMessage.This message is send by the groups client to the server to join a group.
This message is send by the groups client to the server to leave a group.
An event that signals that this node has left a group.
An event that signals that a new member joined a group.
An event that signals that a member has left a group.
This class represents the configuration for the
GroupsClientPlugin.Implements the builder-pattern for this configuration.
This message is send by the groups client to the server.
Decodes
ByteBufs to GroupsClientMessages.Encodes
GroupsClientMessages to ByteBufs.The Groups Membership Client Plugin allows drasyl nodes to connect to membership managers at
startup to join groups.
This class starts a HTTP server with a REST API to manage groups and memberships.
This class represents the configuration for the
GroupsManagerPlugin.Implements the builder-pattern for this configuration.
Starting point for the groups master plugin.
Default class for all messages of the groups plugin.
This message is send by the groups server to the client.
Encodes
GroupsServerMessages to ByteBufs.This class models the connection/join setting of a group.
This message is sent by the groups server to the client when the join to a group was successful.
Util class that provides hashing functions for drasyl.
Hash table based implementation of the
SetMultimap interface.Util class that provides hexadecimal functions for drasyl.
Represents the private identity of a peer (includes the proof of work, the public and private
key).
Class to read/write a
Identity from/to a file.This class models an ed25519 public key that is used as node's unique overlay address.
This class models a ed25519 private key.
Immutable byte array implementation, that do not allow any modifications to the original input.
This event signals that the node was unable to process an inbound message.
A
SortedSet where elements are ordered using their
natural ordering, or by a Comparator provided at set creation
time, depending on which constructor is used.A message that wraps another message with an
InetSocketAddress.Utility class for operations on
InetAddresss.Utility class for operations on
URLs.This Serializer (de)serializes
Integer objects.Represents a pool of unique objects of type
T.This exception is thrown when reading a
RemoteMessage fails due to an invalid format.A serializer based on the Jackson Library for
converting java objects to and from JSON.
This Serializer (de)serializes
Serializable objects.DatabaseAdapter implementation that supports SQL databases.java.util.logging
logger.
Logger factory which creates a
java.util.logging
logger.
Holder for the JSON serializer and JSON deserializer.
This class models a curve25519 public key that is used for x25519 key exchange.
This class models a curve25519 private key that is used for x25519 key exchange.
This class is a simple holder for a key pair (a
IdentityPublicKey and a IdentitySecretKey).This class loads and binds the JNA libdrasyl.
Helper class to load the libsodium library from the preferred location.
Helper class to load the libsodium library from the preferred location.
Our local Chord node.
Provides loggers.
Utility class for logging-related operations.
Defines the set of logging levels.
This Serializer (de)serializes
Long objects.This event signals, that currently all messages from and to the
#peer are only
encrypted with a long time key.Represents a confidential string (like a password or a secret token) whose content is masked in
MaskedString.toString().A decoder that splits received
ByteBufs into frames not larger then MaxLengthFrameDecoder.maxFrameLength.An encoder that splits received
ByteBufs into frames not larger then MaxLengthFrameEncoder.maxFrameLength.Class is used to model the state of a member.
This message is sent by the groups server to the client when a new member has joined a group.
This message is sent by the groups server to the client when a member has left a group.
Class is used to model the state of a group member.
This event signals that the node has received a message addressed to it.
This handler serializes messages to
ByteBuf and vice versa.Helper class to visualize the number of inbound and outbound messages per second.
A map in which more than one value may be associated with and returned for a given key
This class contains methods for MurmurHash3 generation.
This class helps to load native libraries, used with JNA.
Utility class for NAT Port Mapping Protocol (NAT-PMP)-related stuff.
Utility class for network-related operations.
Used by
Event to describe an event related to the local Node (e.g.This event signals that the node is shut down.
Events that refer to a
Node.This event signals that the node has terminated normally.
This event signals that the node is currently not connected to a super peer.
This event signals that the node is currently connected to a super peer.
This event signals that the node encountered an unrecoverable error.
This event signals that the node has been started.
A
RemoteMessage is uniquely identified by its Nonce.NONCE_LENGTH bytes long nonce.A common annotation to declare that annotated elements cannot be
null.As
null values cannot be processed by a Channel, we need a
special type representation this kind of messages.A common annotation to declare that annotated elements can be
null under some
circumstance.This Serializer (de)serializes
null only.Utility class for number-related operations.
Utility class that can be used to detect properties specific to the current runtime
environment/operating system, such as os name.
Traffic shaping handler that limits the number of outgoing messages per second.
Represents the outgoing segment queue that holds segments to be sent over a connection.
A message that wraps another message with a
DrasylAddress.Encodes
OverlayAddressedMessages to AddressedEnvelope messages and vice versa.A tuple of two elements.
Utility class for operations on
Pathes.Used by
Event to describe an event related to a Peer (e.g.This event signals that the node has established a direct connection to a peer.
Represents an endpoint of a drasyl node.
Events that refer to a
Peer.This event signals that communication with this peer is only possible by relaying messages via a
super peer.
A
ChannelHandler that tracks all emitted PathEvents and
generates a list of all peers retrievable through PeersHandler.getPeers().This handler track received
PathEvents and will contain an internal state of all peers,
super peers, children, and available paths.This event signals, that currently all messages from and to the
#peer are encrypted with
an ephemeral session key.Arms (encrypt) outbound and disarms (decrypt) inbound messages.
Utility class that can be used to detect properties specific to the current runtime environment,
such as Java version and the availability of the
sun.misc.Unsafe object.Models environment information of a
DrasylPlugin that are required by the plugin.Static convenience methods that help a method or constructor check whether it was invoked
correctly (that is, whether its preconditions were met).
This class models the proof of work for a given public key.
This Serializer (de)serializes
Message objects.This handler handles subscribers and publications.
Encodes
PubSubMessages to ByteBufs and vice versa.Published
DefaultByteBufHolder.content() ()} to topic PubSubPublish.getTopic().Confirmation of a previous sent
PubSubPublish message.This handler sends
PubSubPublish messages to the PubSubPublishHandler.broker.Subscribes to topic
PubSubSubscribe.getTopic().Confirmation of a previous sent
PubSubSubscribe message.This handler subscribes to topics.
Unsubscribes from topic
PubSubUnsubscribe.getTopic().Confirmation of a previous sent
PubSubUnsubscribe message.Utility class for receiving pseudorandom values.
ReadBufferWaterMark is used to set low water mark and high water mark for the read buffer.
Reads for 60 seconds as fast as possible from a
NioDatagramChannel and prints the
read throughput.Represents the receive buffer that holds incoming data received over a connection.
Remote interface of a Chord node.
Represents the retransmission queue that holds segments that need to be retransmitted due to
timeout or loss in a connection.
Defines a cache for method invocation results of this
Class or methods.The caller of the current remote message invocation will be written to the field with this
annotation.
Signals that a remove message invocation should be canceled.
A
ChannelHandler that can invoke methods on remote objects that are
served on other nodes by RmiServerHandler.Encodes
RmiMessage messages to ByteBufs and vice versa.Indicates that a remote message invocation erroed.
Exception related to remote message invocations.
Remote message invocation-related message.
A invocation of a remote method.
The result of a remote message invocation.
A
ChannelHandler that can serve local object whose methods then can be
invoked by remote nodes using RmiClientHandler.Defines a timeout for all method invocations of this
Class or methods.Utility class for remote method invocation-related operations.
A virtual
Channel for peer communication.A virtual
ServerChannel used for overlay network management.The
ChannelConfig for RustDrasylServerChannels.Utility class for security-related operations.
Message used by
ConnectionHandler to provide reliable and ordered delivery of bytes
between hosts.Encodes
ByteBufs to Segments and vice versa.Represents the send buffer that holds outgoing segments waiting to be sent over a connection.
Holds a
Map with all available Serializers and the classes each serializer should
be used for.This class models the serialized payload of a drasyl application message.
A Serializer represents a bimap between an object and an array of bytes representing that
object.
This class contains some constants with the identifiers of default serializers.
Utility class for serial number arithmetic.
This class holds the current (long time/session | active/inactive/stale)
Agreements between two nodes.Utility class for operations on
Sets.This Serializer (de)serializes
Integer objects.A simple wrapper for the given connection, that does not automatically close in a
try-with-resources block.
SLF4J logger.
Logger factory which creates a SLF4J logger.
A
DefaultEventLoop that is aware of slow task executions.A
DefaultEventLoopGroup that is aware of slow task executions.This handler measures the execution time of
ChannelInboundHandler.channelRead(ChannelHandlerContext, Object) for every
ChannelInboundHandler.This class presents a restricted view to the native sodium library.
This handler spawns the creation of
JavaDrasylChannels to given peers once the server channel
becomes active.This class creates a user-defined number of nodes, which do nothing else than register with the
super peers.
Connection states.
ACK message of the Stop-and-wait ARQ protocol.
Encodes
StopAndWaitArqMessages to ByteBufs and vice versa.DATA message of the Stop-and-wait ARQ protocol.
Performs the Stop-and-wait ARQ protocol.
Message of the Stop-and-wait ARQ protocol.
This Serializer (de)serializes
String objects.Represents an IP range..
Send telemetry data (Neighbour list and, if desired, also the peers' ip addresses) to a given
http endpoint.
Utility class for operations on
Throwables.BiConsumer that can throw checked Exceptions.BiFunction that can throw checked Exceptions.This class implements the token bucket
algorithm as a leaky bucket.
Uses emitted
PathEvents to build the node's current world view of the overlay network.
Send Sequence Space
1 2 3 4
----------|----------|----------|----------
SND.UNA SND.NXT SND.UNA
+SND.WND
1 - old sequence numbers which have been acknowledged
2 - sequence numbers of unacknowledged data
3 - sequence numbers allowed for new data transmission
4 - future sequence numbers which are not yet allowed
A tuple of three elements.
Adapted from netty
TypeParameterMatcherThis class is used for obtaining full generics type information by sub-classing.
This class represents an unsigned short in a rang of [0, 256).
This class represents an unsigned integer in a rang of [0, 2^32)
This class represents an unsigned integer in a rang of [0, 2^24)
This class represents an unsigned short in a rang of [0, 2^16)
Indicates a public API that can change at any time (even in minor/bugfix releases).
Utility class for operations on
URIs.Utility class for operations on
URLs.A
EmbeddedChannel that record all received user events.Helper class to visualize the
ChannelHandler order of a given
ChannelPipeline.Utility class for operations on websocket
URIs (e.g.This class does model a sliding window in the Go-Back-N ARQ protocol.
This class wraps an object of type
T and serves as a write once read many (worm) memory.Writes for 60 seconds as fast as possible to an empty
NioDatagramChannel and prints the
write throughput.