Uses of Interface
org.drasyl.pipeline.Pipeline

Packages that use Pipeline

Package	Description
org.drasyl	Core API that includes the DrasylNode and DrasylConfig.
org.drasyl.monitoring	Monitors various states or events in the drasyl node.
org.drasyl.peer.connection.client	Connects to super peer and other peers.
org.drasyl.peer.connection.direct	Establishes direct connections to other peers.
org.drasyl.peer.connection.handler	netty handlers for peer connections.
org.drasyl.peer.connection.intravm	Automatic discovery of other running drasyl nodes in the same JVM.
org.drasyl.peer.connection.localhost	Uses the file system to discover other drasyl nodes running on the local computer.
org.drasyl.peer.connection.server	Provides a server to which children and other peers can connect.
org.drasyl.pipeline	Link between application and drasyl overlay network.
org.drasyl.plugins	Flexible extensions of drasyl via plugins that can be loaded into the pipeline together with user-defined settings.

Uses of Pipeline in org.drasyl

Methods in org.drasyl that return Pipeline

Modifier and Type	Method	Description
Pipeline	DrasylNode.pipeline()	Returns the Pipeline to allow users to add own handlers.

Constructors in org.drasyl with parameters of type Pipeline

Modifier	Constructor	Description
protected	DrasylNode(DrasylConfig config, Identity identity, PeersManager peersManager, PeerChannelGroup channelGroup, Set<Endpoint> endpoints, AtomicBoolean acceptNewConnections, Pipeline pipeline, List<DrasylNodeComponent> components, PluginManager pluginManager, AtomicBoolean started, CompletableFuture<Void> startSequence, CompletableFuture<Void> shutdownSequence)

Uses of Pipeline in org.drasyl.monitoring

Constructors in org.drasyl.monitoring with parameters of type Pipeline

Modifier	Constructor	Description
	Monitoring(DrasylConfig config, PeersManager peersManager, CompressedPublicKey publicKey, Pipeline pipeline)

Uses of Pipeline in org.drasyl.peer.connection.client

Methods in org.drasyl.peer.connection.client that return Pipeline

Modifier and Type	Method	Description
Pipeline	ClientEnvironment.getPipeline()

Constructors in org.drasyl.peer.connection.client with parameters of type Pipeline

Modifier	Constructor	Description
	ClientEnvironment(DrasylConfig config, Identity identity, Endpoint endpoint, Pipeline pipeline, PeerChannelGroup channelGroup, PeersManager peersManager, boolean joinAsChildren, short idleRetries, Duration idleTimeout, Duration handshakeTimeout)
	DirectClient(DrasylConfig config, Identity identity, PeersManager peersManager, Pipeline pipeline, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, Supplier<Set<Endpoint>> endpointsSupplier, BooleanSupplier directConnectionDemand, Runnable onFailure, BooleanSupplier doNewConnectionsSupplier)
	SuperPeerClient(DrasylConfig config, Identity identity, PeersManager peersManager, Pipeline pipeline, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, BooleanSupplier doNewConnectionsSupplier)

Uses of Pipeline in org.drasyl.peer.connection.direct

Constructors in org.drasyl.peer.connection.direct with parameters of type Pipeline

Modifier	Constructor	Description
	DirectConnectionsManager(DrasylConfig config, Identity identity, PeersManager peersManager, Pipeline pipeline, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, BooleanSupplier acceptNewConnectionsSupplier, Set<Endpoint> endpoints)

Uses of Pipeline in org.drasyl.peer.connection.handler

Fields in org.drasyl.peer.connection.handler declared as Pipeline

Modifier and Type	Field	Description
protected final Pipeline	AbstractThreeWayHandshakeHandler.pipeline
protected final Pipeline	AbstractThreeWayHandshakeHandler.pipeline
protected final Pipeline	AbstractThreeWayHandshakeHandler.pipeline
protected final Pipeline	AbstractThreeWayHandshakeHandler.pipeline

Constructors in org.drasyl.peer.connection.handler with parameters of type Pipeline

Modifier	Constructor	Description
protected	ThreeWayHandshakeClientHandler(int networkId, Identity identity, Duration timeout, Pipeline pipeline, CompletableFuture<Void> handshakeFuture, io.netty.util.concurrent.ScheduledFuture<?> timeoutFuture, R requestMessage)
protected	ThreeWayHandshakeClientHandler(int networkId, Identity identity, Duration timeout, Pipeline pipeline, R requestMessage)
protected	ThreeWayHandshakeServerHandler(Duration timeout, Pipeline pipeline, int networkId, Identity identity)
protected	ThreeWayHandshakeServerHandler(Duration timeout, Pipeline pipeline, CompletableFuture<Void> handshakeFuture, io.netty.util.concurrent.ScheduledFuture<?> timeoutFuture, R requestMessage, O offerMessage, int networkId, Identity identity)

Uses of Pipeline in org.drasyl.peer.connection.intravm

Constructors in org.drasyl.peer.connection.intravm with parameters of type Pipeline

Modifier	Constructor	Description
	IntraVmDiscovery(CompressedPublicKey publicKey, PeersManager peersManager, Pipeline pipeline)

Uses of Pipeline in org.drasyl.peer.connection.localhost

Constructors in org.drasyl.peer.connection.localhost with parameters of type Pipeline

Modifier	Constructor	Description
	LocalHostDiscovery(DrasylConfig config, CompressedPublicKey ownPublicKey, PeersManager peersManager, Set<Endpoint> endpoints, Pipeline pipeline)

Uses of Pipeline in org.drasyl.peer.connection.server

Methods in org.drasyl.peer.connection.server that return Pipeline

Modifier and Type	Method	Description
Pipeline	ServerEnvironment.getPipeline()

Constructors in org.drasyl.peer.connection.server with parameters of type Pipeline

Modifier	Constructor	Description
	Server(Identity identity, Pipeline pipeline, PeersManager peersManager, DrasylConfig config, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, io.netty.channel.EventLoopGroup bossGroup, AtomicBoolean opened, BooleanSupplier acceptNewConnectionsSupplier, Set<Endpoint> nodeEndpoints)	Server for accepting connections from child peers and non-child peers.
	Server(Identity identity, Pipeline pipeline, PeersManager peersManager, DrasylConfig config, PeerChannelGroup channelGroup, io.netty.channel.EventLoopGroup workerGroup, io.netty.channel.EventLoopGroup bossGroup, Set<Endpoint> nodeEndpoints, BooleanSupplier acceptNewConnectionsSupplier)
	ServerEnvironment(DrasylConfig config, Identity identity, PeersManager peersManager, Pipeline pipeline, Set<Endpoint> endpoints, PeerChannelGroup channelGroup, BooleanSupplier acceptedNewConnectionsSupplier)

Uses of Pipeline in org.drasyl.pipeline

Classes in org.drasyl.pipeline that implement Pipeline

Modifier and Type	Class	Description
class	DefaultPipeline	Abstract Pipeline implementation, that needs head and tail.
class	DrasylPipeline	The default Pipeline implementation.
class	EmbeddedPipeline	Embedded Pipeline implementation, that allows easy testing of Handlers.

Methods in org.drasyl.pipeline that return Pipeline

Modifier and Type	Method	Description
Pipeline	DefaultPipeline.addAfter(String baseName, String name, Handler handler)
Pipeline	Pipeline.addAfter(String baseName, String name, Handler handler)	Inserts a Handler after an existing handler of this pipeline.
Pipeline	DefaultPipeline.addBefore(String baseName, String name, Handler handler)
Pipeline	Pipeline.addBefore(String baseName, String name, Handler handler)	Inserts a Handler before an existing handler of this pipeline.
Pipeline	DefaultPipeline.addFirst(String name, Handler handler)
Pipeline	Pipeline.addFirst(String name, Handler handler)	Inserts a Handler at the first position of this pipeline.
Pipeline	DefaultPipeline.addLast(String name, Handler handler)
Pipeline	Pipeline.addLast(String name, Handler handler)	Appends a Handler at the last position of this pipeline.
Pipeline	HandlerContext.pipeline()	Returns the corresponding Pipeline.
Pipeline	DefaultPipeline.remove(String name)
Pipeline	Pipeline.remove(String name)	Removes the Handler with the specified name from this pipeline.
Pipeline	DefaultPipeline.replace(String oldName, String newName, Handler newHandler)
Pipeline	Pipeline.replace(String oldName, String newName, Handler newHandler)	Replaces the Handler of the specified name with a new handler in this pipeline.

Constructors in org.drasyl.pipeline with parameters of type Pipeline

Modifier	Constructor	Description
	DefaultHandlerContext(String name, Handler handler, DrasylConfig config, Pipeline pipeline, io.reactivex.rxjava3.core.Scheduler scheduler, Identity identity, TypeValidator inboundValidator, TypeValidator outboundValidator)	Generates a new default handler context for the given handler.

Uses of Pipeline in org.drasyl.plugins

Methods in org.drasyl.plugins that return Pipeline

Modifier and Type	Method	Description
Pipeline	PluginEnvironment.getPipeline()

Constructors in org.drasyl.plugins with parameters of type Pipeline

Modifier	Constructor	Description
	PluginEnvironment(DrasylConfig config, Identity identity, Pipeline pipeline)
	PluginManager(DrasylConfig config, Identity identity, Pipeline pipeline)