Package org.drasyl.handler.monitoring
Class TelemetryHandler
java.lang.Object
io.netty.channel.ChannelHandlerAdapter
io.netty.channel.ChannelInboundHandlerAdapter
org.drasyl.handler.monitoring.TopologyHandler
org.drasyl.handler.monitoring.TelemetryHandler
- All Implemented Interfaces:
io.netty.channel.ChannelHandler
,io.netty.channel.ChannelInboundHandler
Send telemetry data (Neighbour list and, if desired, also the peers' ip addresses) to a given
http endpoint.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.drasyl.handler.monitoring.TopologyHandler
TopologyHandler.Topology
Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler
io.netty.channel.ChannelHandler.Sharable
-
Field Summary
Fields inherited from class org.drasyl.handler.monitoring.TopologyHandler
childrenPeers, peers, superPeers
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
channelActive
(io.netty.channel.ChannelHandlerContext ctx) void
channelInactive
(io.netty.channel.ChannelHandlerContext ctx) Methods inherited from class org.drasyl.handler.monitoring.TopologyHandler
topology, userEventTriggered
Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter
channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface io.netty.channel.ChannelHandler
handlerAdded, handlerRemoved
-
Constructor Details
-
TelemetryHandler
- Parameters:
submitIntervalSeconds
- how often the current neightbour list should be sent touri
.uri
- HTTP/JSON endpoint to which the neighbour list should be sent.includeIp
- specifies whether the ip addresses of the peers should be transmitted or not.
-
-
Method Details
-
channelActive
- Specified by:
channelActive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelActive
in classio.netty.channel.ChannelInboundHandlerAdapter
- Throws:
Exception
-
channelInactive
- Specified by:
channelInactive
in interfaceio.netty.channel.ChannelInboundHandler
- Overrides:
channelInactive
in classio.netty.channel.ChannelInboundHandlerAdapter
- Throws:
Exception
-