Skip navigation links
A B C D E F G H I J K L M N O P R S T U V W 

A

ack(long) - Method in interface org.thales.punch.libraries.netty.loadcontrol.ILoadController
update the controller statistics.
ack(long) - Method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
 
ack(long) - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
 
ack() - Method in interface org.thales.punch.netty.api.INettyTuple
Acknowledge that NettyData.
ack(Object) - Method in interface org.thales.punch.netty.api.NettyDataAcker
 
ack() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
ack() - Method in class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
ack() - Method in class org.thales.punch.netty.impl.NettyLumberJackTuple
 
ack() - Method in class org.thales.punch.netty.impl.NettyLumberJackTupleEmpty
 
ack() - Method in class org.thales.punch.netty.impl.NettyTupleImpl
 
ack() - Method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
ACK_CONTROL_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
ACK_CONTROL_FRAME_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
ACK_CONTROL_WINDOW_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
add(Destination<T>) - Method in class org.thales.punch.libraries.netty.groups.DestinationLoadBalancer
Add a destination to this load bamancer
add(Destination<T>) - Method in class org.thales.punch.libraries.netty.groups.Group
 
add(ISettingsMap, NettyTcpClient<T>) - Method in class org.thales.punch.libraries.netty.groups.Groups
Add a destination to our groups.
addCertificateToSettings(ISettingsMap) - Static method in class org.thales.punch.netty.impl.NettyConfig
Check if ssl is set in this listeningAddress configuration.
addClientCertificateToSettings(ISettingsMap) - Static method in class org.thales.punch.netty.impl.NettyConfig
Deprecated.
this is actually not used anymore. The IKeys.SSL_CLIENT_CERTIFICATE is not documented anymore.
addDataToFrame(String, String, ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
addItem(NettyLumberjackData) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientRunner
Add an item to be written to the peer.
addListeningAddress(ISettingsMap) - Method in interface org.thales.punch.netty.api.NettySocketServer
Add a listening socket to this server thread.
addListeningAddress(ISettingsMap) - Method in class org.thales.punch.netty.impl.NettyHttpServerImpl
 
addListeningAddress(ISettingsMap) - Method in class org.thales.punch.netty.impl.NettyLumberJackServerImpl
 
addListeningAddress(ISettingsMap) - Method in class org.thales.punch.netty.impl.NettyTcpServerImpl
 
addListeningAddress(ISettingsMap) - Method in class org.thales.punch.netty.impl.NettyUdpServerImpl
 
addListeningAddress(ISettingsMap) - Method in class org.thales.punch.netty.impl.SnmpServerImpl
 
addListeningAddress(ISettingsMap) - Method in class org.thales.punch.netty.relp.impl.NettyRelpServerImpl
 
addPrivateClientKeyToSettings(ISettingsMap) - Static method in class org.thales.punch.netty.impl.NettyConfig
Deprecated.
addPrivateKeyToSettings(ISettingsMap) - Static method in class org.thales.punch.netty.impl.NettyConfig
Check if ssl is set in this listeningAddress configuration.
addSizeToFrame(int, ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
addTrustedCertificateToSettings(ISettingsMap) - Static method in class org.thales.punch.netty.impl.NettyConfig
Check if ssl is set in this address settings configuration.

B

bind(ChannelHandlerContext, SocketAddress, ChannelPromise) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
bootstrap - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
our netty client bootstrap.
bossGroup - Variable in class org.thales.punch.netty.impl.NettyAbstractServer
 
build(ISettingsMap) - Static method in class org.thales.punch.netty.api.NettyEndPointAddress
Create a netty endpoint fro your settings.
build() - Method in class org.thales.punch.netty.relp.proto.RELPFrame.Builder
 
Builder() - Constructor for class org.thales.punch.netty.impl.UdpTable.Builder
 
Builder() - Constructor for class org.thales.punch.netty.relp.proto.RELPFrame.Builder
 

C

callback - Variable in class org.thales.punch.netty.impl.NettyServerDataHandler
the data receiver
channelActive(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
channelActive(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.NettyServerDataHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
channelInactive(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.NettyServerDataHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
channelRead(ChannelHandlerContext, Object) - Method in class org.thales.punch.netty.impl.NettyHttpServerHandler
 
channelRead0(ChannelHandlerContext, ByteBuf) - Method in class org.thales.punch.netty.impl.NettyClientByteBufDataHandlerHandler
 
channelRead0(ChannelHandlerContext, String) - Method in class org.thales.punch.netty.impl.NettyClientDataHandler
 
channelRead0(ChannelHandlerContext, HttpObject) - Method in class org.thales.punch.netty.impl.NettyHttpClientHandler
 
channelRead0(ChannelHandlerContext, T) - Method in class org.thales.punch.netty.impl.NettyServerDataHandler
 
channelRead0(ChannelHandlerContext, DatagramPacket) - Method in class org.thales.punch.netty.impl.NettyUdpBytesDataHandler
 
channelRead0(ChannelHandlerContext, DatagramPacket) - Method in class org.thales.punch.netty.impl.NettyUdpByteToStringDataHandler
 
channelRead0(ChannelHandlerContext, DatagramPacket) - Method in class org.thales.punch.netty.impl.NettyUdpDataHandler
 
channelRead0(ChannelHandlerContext, RELPFrame) - Method in class org.thales.punch.netty.relp.impl.NettyRelpDataHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.NettyHttpServerHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.NettyUdpBytesDataHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.NettyUdpByteToStringDataHandler
 
channelReadComplete(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.NettyUdpDataHandler
 
channelRegistered(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
channelUnregistered(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
CliCommand - Class in org.thales.punch.libraries.commons.cli
Facility Class to create a java command line application.
CliCommand() - Constructor for class org.thales.punch.libraries.commons.cli.CliCommand
 
close(ChannelHandlerContext, ChannelPromise) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
close() - Method in class org.thales.punch.netty.relp.proto.RELPClient
Close this client.
close() - Method in class org.thales.punch.netty.relp.utils.RELPClient
Close this client.
CMD_CLOSE - Static variable in class org.thales.punch.netty.relp.proto.RELPFrame
close command to terminate a relp handshake.
CMD_OPEN - Static variable in class org.thales.punch.netty.relp.proto.RELPFrame
open command to initiate a relp handshake.
CODEC_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
command(String) - Method in class org.thales.punch.netty.relp.proto.RELPFrame.Builder
 
CommandLineRunner - Class in org.thales.punch.libraries.commons.cli
A Facility to create command line java applications.
CommandLineRunner() - Constructor for class org.thales.punch.libraries.commons.cli.CommandLineRunner
 
compareTo(Destination<T>) - Method in class org.thales.punch.libraries.netty.groups.Destination
 
compareTo(Group<T>) - Method in class org.thales.punch.libraries.netty.groups.Group
 
compareTo(NettyEndPointAddress) - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
COMPRESS_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
CompressionRatio(Counter, Counter) - Constructor for class org.thales.punch.netty.impl.NettyInitializer.CompressionRatio
Return a compression ratio
configure(ISettingsMap) - Method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
Configure a load controller.
configure(ISettingsMap) - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
 
connect(ChannelHandlerContext, SocketAddress, SocketAddress, ChannelPromise) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
connect(AtomicBoolean) - Method in class org.thales.punch.netty.impl.NettyAbstractClient
connect to the server.
CONNECT_INTERVAL_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
CONNECT_RETRY_INTERVAL_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
connected(Destination<T>) - Method in class org.thales.punch.libraries.netty.groups.Group
Callback whenever the connection to one destination suceeded.
CONTENT - Static variable in class org.thales.punch.netty.impl.NettyHttpTuple
Field used to pass the data received from POST requests.

D

data(byte[]) - Method in class org.thales.punch.netty.relp.proto.RELPFrame.Builder
 
dataLength(int) - Method in class org.thales.punch.netty.relp.proto.RELPFrame.Builder
 
debug() - Method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
dump some useful infos.
debug() - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
dump some useful infos.
debug(String, Object...) - Method in class org.thales.punch.netty.loggers.PeriodicLoggerWrapper
 
decode(ByteBuf) - Method in interface org.thales.punch.libraries.commons.netty.codec.NettyCodec
Decode a received payload and return the decoded info as one or several strings
decode(ByteBuf) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowDecoder
Decode a received payload and return the lumberjack frames contained in it.
decode(byte[]) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowDecoder
Decode a received payload and return the lumberjack frames contained in it.
decode(ByteBuf) - Method in class org.thales.punch.libraries.commons.netty.codec.NettySnmpDecoder
 
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.thales.punch.netty.handler.codec.FixedLengthFrameDecoder
 
decode(ChannelHandlerContext, ByteBuf) - Method in class org.thales.punch.netty.handler.codec.FixedLengthFrameDecoder
Create a frame out of the ByteBuf and return it.
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.thales.punch.netty.handler.codec.LineBasedFrameDecoder
 
decode(ChannelHandlerContext, ByteBuf) - Method in class org.thales.punch.netty.handler.codec.LineBasedFrameDecoder
Create a frame out of the ByteBuf and return it.
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.thales.punch.netty.handler.codec.RelpFrameDecoder
 
decode(ChannelHandlerContext, ByteBuf) - Method in class org.thales.punch.netty.handler.codec.RelpFrameDecoder
Create a frame out of the ByteBuf and return it.
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
 
decode(ChannelHandlerContext, ByteBuf) - Method in class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
Create a frame out of the ByteBuf and return it.
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.thales.punch.netty.handler.codec.SyslogOctetCountFrameDecoder
 
decode(ChannelHandlerContext, ByteBuf, List<Object>) - Method in class org.thales.punch.netty.impl.MonitoredStringDecoder
 
decode(ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberjackDecoder
Decode a received payload and return the lumberjack frames contained in it.
decode(byte[]) - Method in class org.thales.punch.netty.impl.NettyLumberjackDecoder
Decode a received payload and return the lumberjack frames contained in it.
decode(byte[], int) - Method in class org.thales.punch.netty.impl.NettyLumberjackDecoder
Decode a received payload at some starting offset and return the lumberjack frames contained in it.
decodeComplete(ByteBuffer) - Method in class org.thales.punch.netty.impl.NettyLumberjackDecoder
Decode a received payload.
decodeMultiPart(int, Map<String, Object>) - Static method in class org.thales.punch.netty.impl.NettyHttpServerHandler
If required replace the content by a decoded document containing the byte arrays for each multipart.
DELIMITER - Static variable in class org.thales.punch.netty.relp.proto.RELPFrame
 
deregister(ChannelHandlerContext, ChannelPromise) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
Destination<T> - Class in org.thales.punch.libraries.netty.groups
A destination encapsulate a Netty TCP client.
Destination(int, Group<T>, NettyTcpClient<T>) - Constructor for class org.thales.punch.libraries.netty.groups.Destination
Ctor
DESTINATION_KEY - Static variable in class org.thales.punch.libraries.netty.groups.GroupConfig
The array of destinations.
DestinationLoadBalancer<T> - Class in org.thales.punch.libraries.netty.groups
A destination load balancer returns each destination using a round robin strategy.
DestinationLoadBalancer() - Constructor for class org.thales.punch.libraries.netty.groups.DestinationLoadBalancer
Ctor
disconnect(ChannelHandlerContext, ChannelPromise) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
disconnected(Destination<T>) - Method in class org.thales.punch.libraries.netty.groups.Group
Callback whenever the connection to one destination failed.
DROP_IF_SLOW - Static variable in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
DROP_IF_SLOW_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyTcpClientImpl
 

E

encode(ChannelHandlerContext, CharSequence, List<Object>) - Method in class org.thales.punch.netty.impl.MonitoredStringEncoder
 
encode(RELPFrame) - Method in class org.thales.punch.netty.relp.proto.RELPEncoder
 
encodev5Header(Map<String, Object>) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Encode a Netflow v5 Header
encodev5Record(Map<String, Object>) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Add a Netflow v5 record.
encodev9Data(int, int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Encode a v9 template flowset.
encodev9DataByte(int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9DataInt(int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9DataInt24(int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9DataIpv6(String) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9DataMac(String) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9DataShort(int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9DataString(String) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9Header(Map<String, Object>) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Encode a Netflow v5 Header
encodev9Option(int, int, int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Encode a v9 template flowset.
encodev9OptionField(int, int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9OptionField(int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9OptionScopeField(int, int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9Padding(int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9Template(int, int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
encodev9TemplateField(int, int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Encode a template field, using the default length as defined in the Netflow field standard.
encodev9TemplateField(int) - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Encode a template field, using the default length as defined in the Netflow field standard.
endDataFrame(ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
equals(Object) - Method in class org.thales.punch.libraries.netty.groups.Destination
 
equals(Object) - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
error(String, Object...) - Method in class org.thales.punch.netty.loggers.PeriodicLoggerWrapper
 
error(long) - Static method in class org.thales.punch.netty.relp.proto.RELPResponse
Utility method to create a default "ERROR" response.
ERROR_CODE - Static variable in class org.thales.punch.netty.relp.proto.RELPResponse
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.thales.punch.netty.impl.NettyClientByteBufDataHandlerHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.thales.punch.netty.impl.NettyClientDataHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.thales.punch.netty.impl.NettyHttpClientHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.thales.punch.netty.impl.NettyHttpServerHandler
 
exceptionCaught(ChannelHandlerContext, Throwable) - Method in class org.thales.punch.netty.impl.NettyServerDataHandler
 
ExponentialAverage - Class in org.thales.punch.libraries.netty.loadcontrol
A simple class to provide a moving exponential average value.
ExponentialAverage() - Constructor for class org.thales.punch.libraries.netty.loadcontrol.ExponentialAverage
 

F

factory(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
Return a load controller as configured in the settings.
fail(long) - Method in interface org.thales.punch.libraries.netty.loadcontrol.ILoadController
update the controller statistics.
fail(long) - Method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
 
fail(long) - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
 
fail() - Method in interface org.thales.punch.netty.api.INettyTuple
Signal the peer about the failure to process that NettyData.
fail(Object) - Method in interface org.thales.punch.netty.api.NettyDataAcker
 
fail() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
fail() - Method in class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
fail() - Method in class org.thales.punch.netty.impl.NettyLumberJackTuple
 
fail() - Method in class org.thales.punch.netty.impl.NettyLumberJackTupleEmpty
 
fail() - Method in class org.thales.punch.netty.impl.NettyTupleImpl
 
fail() - Method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
fatal(String, Object...) - Method in class org.thales.punch.netty.loggers.PeriodicLoggerWrapper
 
FixedLengthFrameDecoder - Class in org.thales.punch.netty.handler.codec
A decoder that splits the received ByteBufs by the fixed number of bytes.
FixedLengthFrameDecoder(int) - Constructor for class org.thales.punch.netty.handler.codec.FixedLengthFrameDecoder
Creates a new instance.
flush(ChannelHandlerContext) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
flush() - Method in class org.thales.punch.netty.relp.proto.RELPClient
 
flush() - Method in class org.thales.punch.netty.relp.utils.RELPClient
 
format(ChannelHandlerContext, String) - Static method in class org.thales.punch.netty.impl.MonitoringHandler
 
formatByteBuf(String, ByteBuf) - Static method in class org.thales.punch.netty.impl.MonitoringHandler
Returns a String which contains all details to log the ByteBuf
formatByteBufHolder(String, ByteBufHolder) - Static method in class org.thales.punch.netty.impl.MonitoringHandler
Returns a String which contains all details to log the ByteBufHolder.
formatMessage(String, Object) - Static method in class org.thales.punch.netty.impl.MonitoringHandler
 
formatNonByteBuf(String, Object) - Static method in class org.thales.punch.netty.impl.MonitoringHandler
Returns a String which contains all details to log the Object
fromFiles(String...) - Static method in class org.thales.punch.netty.impl.UdpTable.Builder
 

G

get(INettyTuple<T>) - Method in class org.thales.punch.netty.api.UtilNettyValueGetter
 
getAddress() - Method in class org.thales.punch.netty.impl.UdpTable.Host
 
getAppRecvCounter() - Method in class org.thales.punch.netty.impl.NettyInitializer
 
getAppSentCounter() - Method in class org.thales.punch.netty.impl.NettyInitializer
 
getByLocalPort(int) - Method in class org.thales.punch.netty.impl.UdpTable
Get all socket that matching local port
getBytes() - Method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
Get the complete Netflow payload as a byte array
getChannel() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getCharset() - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
getCharset() - Method in class org.thales.punch.netty.relp.proto.RELPEncoder
 
getClient() - Method in class org.thales.punch.libraries.netty.groups.Destination
 
getCommand() - Method in class org.thales.punch.netty.relp.proto.RELPFrame
 
getConfiguredWeight() - Method in class org.thales.punch.libraries.netty.groups.Group
 
getConnectIntervalMs() - Method in class org.thales.punch.netty.impl.NettyAbstractClient
 
getConnectRetryIntervalMs() - Method in class org.thales.punch.netty.impl.NettyAbstractClient
 
getContext() - Method in class org.thales.punch.netty.impl.NettyLumberjackData
 
getCurrentRate() - Method in interface org.thales.punch.libraries.netty.loadcontrol.ILoadController
 
getCurrentRate() - Method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
 
getCurrentRate() - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
 
getData() - Method in interface org.thales.punch.netty.api.INettyTuple
The general case is to receive a Json document (as is, or lumberjack encoded), made of key value pairs.
getData() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getData() - Method in class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
getData() - Method in class org.thales.punch.netty.impl.NettyLumberjackData
 
getData() - Method in class org.thales.punch.netty.impl.NettyLumberJackTuple
 
getData() - Method in class org.thales.punch.netty.impl.NettyLumberJackTupleEmpty
 
getData() - Method in class org.thales.punch.netty.impl.NettyTupleImpl
 
getData() - Method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
getData() - Method in class org.thales.punch.netty.relp.proto.RELPFrame
 
getDataLength() - Method in interface org.thales.punch.netty.api.INettyTuple
 
getDataLength() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getDataLength() - Method in class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
getDataLength() - Method in class org.thales.punch.netty.impl.NettyLumberJackTuple
 
getDataLength() - Method in class org.thales.punch.netty.impl.NettyLumberJackTupleEmpty
 
getDataLength() - Method in class org.thales.punch.netty.impl.NettyTupleImpl
 
getDataLength() - Method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
getDataLength() - Method in class org.thales.punch.netty.relp.proto.RELPFrame
 
getDirectResponse() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getDrops() - Method in class org.thales.punch.netty.impl.UdpTable.Socket
 
getEffectiveWeight() - Method in class org.thales.punch.libraries.netty.groups.Group
 
getFileFromString(String) - Static method in class org.thales.punch.netty.impl.NettyAbstractEndpoint
Fail stop method to create a temporary file from a string content.
getFrame(ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
Convert one lumberjack frame to an encoded byte array
getFrame(ByteBuf[], int) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
Deprecated. 
getFrame() - Method in class org.thales.punch.netty.relp.proto.RELPDecoder
Returns the decoded frame and resets the decoder for the next frame.
getHost() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
getHttpClient(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Returns a HTTP client.
getHttpClient(ISettingsMap, IMetricContext, NettyDataAcker) - Static method in class org.thales.punch.netty.api.NettyFactory
Returns a HTTP client.
getHttpServer(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return an HTTP server.
getId() - Method in interface org.thales.punch.libraries.commons.netty.codec.NetflowElement
 
getId() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowField
 
getId() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowScope
 
getJsonValue() - Method in class org.thales.punch.snmp.SNMPValue
 
getKeepAlive() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getLength() - Method in interface org.thales.punch.libraries.commons.netty.codec.NetflowElement
 
getLength() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowField
 
getLength() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowScope
 
getLocal() - Method in class org.thales.punch.netty.impl.UdpTable.Socket
 
getLocalAddress() - Method in interface org.thales.punch.netty.api.INettyTuple
Get the local (i.e.
getLocalAddress() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getLocalAddress() - Method in class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
getLocalAddress() - Method in class org.thales.punch.netty.impl.NettyLumberJackTuple
 
getLocalAddress() - Method in class org.thales.punch.netty.impl.NettyLumberJackTupleEmpty
 
getLocalAddress() - Method in class org.thales.punch.netty.impl.NettyTupleImpl
 
getLocalAddress() - Method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
getLogger(Class<?>) - Static method in class org.thales.punch.netty.loggers.PeriodicLoggerWrapper
 
getLumberjackClient(ISettingsMap, IMetricContext, NettyDataAcker) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a TCP client.
getMap() - Method in class org.thales.punch.netty.impl.NettyLumberjackData
 
getName() - Method in class org.thales.punch.libraries.netty.groups.Group
 
getNextDestination() - Method in class org.thales.punch.libraries.netty.groups.DestinationLoadBalancer
 
getPort() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
getPort() - Method in class org.thales.punch.netty.impl.UdpTable.Host
 
getRatio() - Method in class org.thales.punch.netty.impl.NettyInitializer.CompressionRatio
 
getRawRecvCounter() - Method in class org.thales.punch.netty.impl.NettyInitializer
 
getRawSentCounter() - Method in class org.thales.punch.netty.impl.NettyInitializer
 
getRelpServer(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a plain TCP server.
getRemote() - Method in class org.thales.punch.netty.impl.UdpTable.Socket
 
getRemoteAddress() - Method in interface org.thales.punch.netty.api.INettyTuple
Get the remote (i.e.
getRemoteAddress() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getRemoteAddress() - Method in class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
getRemoteAddress() - Method in class org.thales.punch.netty.impl.NettyLumberJackTuple
 
getRemoteAddress() - Method in class org.thales.punch.netty.impl.NettyLumberJackTupleEmpty
 
getRemoteAddress() - Method in class org.thales.punch.netty.impl.NettyTupleImpl
 
getRemoteAddress() - Method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
getRoundTripTime() - Method in class org.thales.punch.netty.impl.NettyLumberjackData
 
getSeqNum() - Method in class org.thales.punch.netty.impl.NettyLumberjackData
 
getServer(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a line based UDP or TCP server.
getSnmpServer(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a Line based TCP server.
getSslContext() - Method in class org.thales.punch.netty.impl.NettyAbstractClient
Return the ssl context associated to this client.
getSslProvider(String) - Method in class org.thales.punch.netty.impl.NettyAbstractEndpoint
Retrieve the sslPorvider class from the name.
getTcpClient(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
 
getTcpClient(ISettingsMap, IMetricContext, NettyDataAcker) - Static method in class org.thales.punch.netty.api.NettyFactory
 
getTcpLumberjackServer(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a TCP Lumberjack Server server.
getTcpServer(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a Line based TCP server.
getTxnr() - Method in class org.thales.punch.netty.relp.proto.RELPFrame
 
getType() - Method in interface org.thales.punch.libraries.commons.netty.codec.NetflowElement
 
getType() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowField
 
getType() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowScope
 
getType() - Method in interface org.thales.punch.netty.api.INettyReaderCallback
 
getType() - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
getType() - Method in class org.thales.punch.netty.impl.NettyHttpServerImpl
 
getType() - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
getType() - Method in class org.thales.punch.snmp.SNMPValue
 
getUdpClient(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a UDP client.
getUdpServer(ISettingsMap, IMetricContext) - Static method in class org.thales.punch.netty.api.NettyFactory
Return a TCP server.
getUniqueID() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
getValue(String, INettyTuple<T>) - Method in interface org.thales.punch.netty.api.INettyTupleValueGetter
 
getWeight() - Method in class org.thales.punch.libraries.netty.groups.Destination
 
Group<T> - Class in org.thales.punch.libraries.netty.groups
A Group of destination.
Group(Groups<T>, String) - Constructor for class org.thales.punch.libraries.netty.groups.Group
 
GROUP_CONNECTION_TIMEOUT_KEY - Static variable in class org.thales.punch.libraries.netty.groups.GroupConfig
should no connections be available at all in no groups, you can make the start wait for that amount of time.
GroupConfig - Class in org.thales.punch.libraries.netty.groups
The settings property names associated to groups.
Groups<T> - Class in org.thales.punch.libraries.netty.groups
A group encapsulates several destinations.
Groups() - Constructor for class org.thales.punch.libraries.netty.groups.Groups
 

H

hashCode() - Method in class org.thales.punch.libraries.netty.groups.Destination
 
hashCode() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
hasMap() - Method in class org.thales.punch.netty.impl.NettyLumberjackData
 
host - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
The listening or destination host host ip address.
HTTP_COMPRESS_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 

I

ILoadController - Interface in org.thales.punch.libraries.netty.loadcontrol
ILoadController allows you to regulate your data emitting to some fixed rate, or using an adaptative strategy should you need to slow down automatically in case the downstream latency increases.
INettyConnectionCallback - Interface in org.thales.punch.netty.api
A callback to be told upon connections/disconnections
INettyReaderCallback<T> - Interface in org.thales.punch.netty.api
Called when a NettySocketServer has received data.
INettyTuple<T> - Interface in org.thales.punch.netty.api
You receive INettyTuple whenever a netty client or server receives some data.
INettyTupleValueGetter<T> - Interface in org.thales.punch.netty.api
WHen retrieving values from netty tuples, it may ne required to efficiently retrieve named values.
info(String, Object...) - Method in class org.thales.punch.netty.loggers.PeriodicLoggerWrapper
 
init() - Static method in class org.thales.punch.libraries.commons.netty.codec.NetflowField
You must call this method before anything else.
initChannel(SocketChannel) - Method in class org.thales.punch.netty.impl.NettyInitializerClient
 
initChannel(SocketChannel) - Method in class org.thales.punch.netty.impl.NettyInitializerHttpClient
 
initChannel(SocketChannel) - Method in class org.thales.punch.netty.impl.NettyInitializerHttpServer
 
initChannel(SocketChannel) - Method in class org.thales.punch.netty.impl.NettyInitializerLumberjackClient
 
initChannel(SocketChannel) - Method in class org.thales.punch.netty.impl.NettyInitializerLumberjackServer
 
initChannel(SocketChannel) - Method in class org.thales.punch.netty.impl.NettyInitializerServer
 
initChannel(SocketChannel) - Method in class org.thales.punch.netty.relp.impl.NettyInitializerRelpServer
 
IRELPClientCallback - Interface in org.thales.punch.netty.relp.proto
A simple RELP callback to work with the client
IRELPClientCallback - Interface in org.thales.punch.netty.relp.utils
A simple RELP callback to work with the client
isActive() - Method in class org.thales.punch.libraries.netty.groups.Groups
 
isCompressed() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
isConnected() - Method in class org.thales.punch.libraries.netty.groups.Destination
 
isHttpCompressed() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
isHttpProto() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
isLumberjackCompressed() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
isLumberkackProto() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
isRepresentedAsStringInJson() - Method in enum org.thales.punch.snmp.SNMPValueType
 
isSnmpEndpoint() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
isStopped() - Method in interface org.thales.punch.netty.api.NettySocketServer
 
isStopped() - Method in class org.thales.punch.netty.impl.NettyAbstractServer
 
isStopped() - Method in class org.thales.punch.netty.impl.NettyUdpServerImpl
 
isStopped() - Method in class org.thales.punch.netty.impl.SnmpServerImpl
 
isTcpProto() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
isTimestamp() - Method in interface org.thales.punch.libraries.commons.netty.codec.NetflowElement
 
isTimestamp() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowField
 
isTimestamp() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowScope
 
isUdpProto() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
Item(String) - Constructor for class org.thales.punch.netty.impl.NettyTcpClientImpl.Item
 

J

jsonFromPdu(PDU, Address, byte[]) - Static method in class org.thales.punch.netty.impl.SnmpServerImpl
 

K

KEEPALIVE_INTERVAL_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
KEEPALIVE_TIMEOUT_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 

L

lastStatTimestamp - Variable in class org.thales.punch.libraries.netty.loadcontrol.LoadController
 
limitedUsage(String) - Method in class org.thales.punch.libraries.commons.cli.CommandLineRunner
default ctor *./ public CommandLineRunner() { super(); } /** print the basic help with the list of available commands and how to gain more details using the help option, if any.
LineBasedFrameDecoder - Class in org.thales.punch.netty.handler.codec
Implements a Netty ByteToMessageDecoder for the Syslog octet counting framing.
LineBasedFrameDecoder(int) - Constructor for class org.thales.punch.netty.handler.codec.LineBasedFrameDecoder
Creates a new decoder.
LineBasedFrameDecoder(int, boolean, boolean) - Constructor for class org.thales.punch.netty.handler.codec.LineBasedFrameDecoder
Creates a new decoder.
LoadController - Class in org.thales.punch.libraries.netty.loadcontrol
This class provides the factory to create Load Controllers, and also provides the default implementation that let all the traffic pass.
LoadController(IMetricContext) - Constructor for class org.thales.punch.libraries.netty.loadcontrol.LoadController
All load controller benefit from the pending metric, that reports the current number pf pending tuples in the topology.
LOG - Static variable in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
LOG - Static variable in class org.thales.punch.libraries.commons.netty.codec.NettySnmpDecoder
 
LOG - Static variable in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
logger - Static variable in class org.thales.punch.libraries.netty.groups.Group
 
logger - Static variable in class org.thales.punch.libraries.netty.groups.Groups
 
LUMBERJACK_COMPRESS_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 

M

markAsTimestamp() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowField
 
MAX_FRAME_SIZE_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
MAX_FRAME_SIZE_KEY - Static variable in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
MAX_PAYLOAD_LENGTH_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
maxPayloadLength - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
max allowed length
METRIC_PREFIX_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
metricsContext - Variable in class org.thales.punch.netty.api.NettyUdpClientImpl
our injected metrics context
metricsContext - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
our injected metrics context
MonitoredStringDecoder - Class in org.thales.punch.netty.impl
Decodes a received ByteBuf into a String.
MonitoredStringDecoder(Counter) - Constructor for class org.thales.punch.netty.impl.MonitoredStringDecoder
Creates a new instance with the current system character set.
MonitoredStringDecoder(Charset) - Constructor for class org.thales.punch.netty.impl.MonitoredStringDecoder
Creates a new instance with the specified character set.
MonitoredStringEncoder - Class in org.thales.punch.netty.impl
Encodes the requested String into a ByteBuf.
MonitoredStringEncoder(Counter) - Constructor for class org.thales.punch.netty.impl.MonitoredStringEncoder
Creates a new instance with the current system character set.
MonitoredStringEncoder(Charset) - Constructor for class org.thales.punch.netty.impl.MonitoredStringEncoder
Creates a new instance with the specified character set.
MonitoringHandler - Class in org.thales.punch.netty.impl
A ChannelHandler that logs all events using a logging framework.
MonitoringHandler(Counter, Counter) - Constructor for class org.thales.punch.netty.impl.MonitoringHandler
Creates a new instance to monitor your pipeline

N

NetflowElement - Interface in org.thales.punch.libraries.commons.netty.codec
Codecs are designed to get binary data from UDP or TCP and return decoded information.
NetflowElement.Type - Enum in org.thales.punch.libraries.commons.netty.codec
 
NetflowField - Class in org.thales.punch.libraries.commons.netty.codec
Codecs are designed to get binary data from UDP or TCP and return decoded information.
NetflowField(int, String, NetflowElement.Type) - Constructor for class org.thales.punch.libraries.commons.netty.codec.NetflowField
Ctor
NetflowField(int, int) - Constructor for class org.thales.punch.libraries.commons.netty.codec.NetflowField
 
NetflowScope - Class in org.thales.punch.libraries.commons.netty.codec
Codecs are designed to get binary data from UDP or TCP and return decoded information.
NetflowScope(int, int) - Constructor for class org.thales.punch.libraries.commons.netty.codec.NetflowScope
 
NettyAbstractClient - Class in org.thales.punch.netty.impl
The NIO client sends out events as string on a tcp socket.
NettyAbstractClient(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyAbstractClient
Common constructor for all clients.
NettyAbstractEndpoint - Class in org.thales.punch.netty.impl
Netty endpoints (server or client) use many shared configuration items.
NettyAbstractEndpoint(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyAbstractEndpoint
 
NettyAbstractServer - Class in org.thales.punch.netty.impl
This class group commons settings for TCP servers.
NettyAbstractServer(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyAbstractServer
Ctor
NettyClientByteBufDataHandlerHandler - Class in org.thales.punch.netty.impl
Handles a client-side ByteBuf channel.
NettyClientByteBufDataHandlerHandler(NettyReaderByteBufCallback, Counter, Counter, String) - Constructor for class org.thales.punch.netty.impl.NettyClientByteBufDataHandlerHandler
Ctor
NettyClientDataHandler - Class in org.thales.punch.netty.impl
Handles a client-side channel.
NettyClientDataHandler(INettyReaderCallback<String>) - Constructor for class org.thales.punch.netty.impl.NettyClientDataHandler
 
NettyCodec - Interface in org.thales.punch.libraries.commons.netty.codec
Codecs are designed to get binary data from UDP or TCP and return decoded information.
NettyConfig - Class in org.thales.punch.netty.impl
This defines the Netty related configuration default value plus a few utility methods.
NettyDataAcker - Interface in org.thales.punch.netty.api
Callback to be notified upon an acknowledgement of some data sent over a TCP peer.
NettyEndPointAddress - Class in org.thales.punch.netty.api
Configuration is always difficult.
NettyEndPointAddress(String, String, int, boolean) - Constructor for class org.thales.punch.netty.api.NettyEndPointAddress
 
NettyException - Exception in org.thales.punch.netty.impl
 
NettyException() - Constructor for exception org.thales.punch.netty.impl.NettyException
 
NettyException(String) - Constructor for exception org.thales.punch.netty.impl.NettyException
 
NettyException(Throwable) - Constructor for exception org.thales.punch.netty.impl.NettyException
 
NettyException(String, Throwable) - Constructor for exception org.thales.punch.netty.impl.NettyException
 
NettyException(String, Object...) - Constructor for exception org.thales.punch.netty.impl.NettyException
Syntactic sugar for message formatting.
NettyException(Throwable, String, Object...) - Constructor for exception org.thales.punch.netty.impl.NettyException
Syntactic sugar for message formatting.
NettyException(String, Throwable, boolean, boolean) - Constructor for exception org.thales.punch.netty.impl.NettyException
 
NettyFactory - Class in org.thales.punch.netty.api
The factor class to get TCP clients or servers.
NettyHttpClientHandler - Class in org.thales.punch.netty.impl
Handles a client-side HTTP channel.
NettyHttpClientHandler(INettyReaderCallback<Map<String, Object>>, Counter, Counter) - Constructor for class org.thales.punch.netty.impl.NettyHttpClientHandler
 
NettyHttpClientImpl - Class in org.thales.punch.netty.impl
The HttpClient.
NettyHttpClientImpl(ISettingsMap, IMetricContext, NettyDataAcker) - Constructor for class org.thales.punch.netty.impl.NettyHttpClientImpl
Return a new NettyHttpTcpClient.
NettyHttpServerHandler - Class in org.thales.punch.netty.impl
Handles a http server-side channel.
NettyHttpServerHandler(INettyReaderCallback<Map<String, Object>>, Counter, Counter, boolean, int) - Constructor for class org.thales.punch.netty.impl.NettyHttpServerHandler
Ctor
NettyHttpServerImpl - Class in org.thales.punch.netty.impl
An extra simple Netty TCP server, reading lines from a TCP socket.
NettyHttpServerImpl(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyHttpServerImpl
Create a new single-threaded asynchronous TCP server.
NettyHttpTuple - Class in org.thales.punch.netty.impl
Netty Tuple to receive http content.
NettyHttpTupleEmpty - Class in org.thales.punch.netty.impl
 
NettyHttpTupleEmpty(Map<String, String>) - Constructor for class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
NettyHttpTupleEmpty() - Constructor for class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
NettyInitializer - Class in org.thales.punch.netty.impl
All initializers share the metrics, the compression and the ssl context (if any).
NettyInitializer(IMetricContext, SslContext, boolean, long, String) - Constructor for class org.thales.punch.netty.impl.NettyInitializer
 
NettyInitializer.CompressionRatio - Class in org.thales.punch.netty.impl
 
NettyInitializerClient - Class in org.thales.punch.netty.impl
Creates a newly configured ChannelPipeline for a new channel.
NettyInitializerClient(INettyReaderCallback<String>, IMetricContext, SslContext, boolean, String, int, int, long) - Constructor for class org.thales.punch.netty.impl.NettyInitializerClient
 
NettyInitializerHttpClient - Class in org.thales.punch.netty.impl
Creates a newly configured ChannelPipeline for a new channel.
NettyInitializerHttpClient(INettyReaderCallback<Map<String, Object>>, IMetricContext, SslContext, String, int, boolean, long) - Constructor for class org.thales.punch.netty.impl.NettyInitializerHttpClient
Initialzer for the http client netty channel.
NettyInitializerHttpServer - Class in org.thales.punch.netty.impl
Creates a newly configured ChannelPipeline for a new channel.
NettyInitializerHttpServer(INettyReaderCallback<Map<String, Object>>, IMetricContext, SslContext, boolean, long, boolean, int) - Constructor for class org.thales.punch.netty.impl.NettyInitializerHttpServer
Initializer for the http netty channel.
NettyInitializerLumberjackClient - Class in org.thales.punch.netty.impl
Creates a newly configured ChannelPipeline for a new channel.
NettyInitializerLumberjackClient(NettyReaderByteBufCallback, IMetricContext, SslContext, String, int, boolean, long) - Constructor for class org.thales.punch.netty.impl.NettyInitializerLumberjackClient
Initialzer for the lumberjack client netty channel.
NettyInitializerLumberjackServer - Class in org.thales.punch.netty.impl
Creates a newly configured ChannelPipeline for a new channel.
NettyInitializerLumberjackServer(NettyReaderByteBufCallback, IMetricContext, SslContext, boolean, long, String) - Constructor for class org.thales.punch.netty.impl.NettyInitializerLumberjackServer
Initialzer for the lumberjack netty channel.
NettyInitializerRelpServer - Class in org.thales.punch.netty.relp.impl
Creates a newly configured ChannelPipeline for a new channel.
NettyInitializerRelpServer(INettyReaderCallback<RELPFrame>, IMetricContext, SslContext, boolean, int, long) - Constructor for class org.thales.punch.netty.relp.impl.NettyInitializerRelpServer
Ctor
NettyInitializerServer<T> - Class in org.thales.punch.netty.impl
Creates a newly configured ChannelPipeline for a new channel.
NettyInitializerServer(INettyReaderCallback<T>, IMetricContext, SslContext, boolean, long, Supplier<ChannelHandler>) - Constructor for class org.thales.punch.netty.impl.NettyInitializerServer
 
NettyLumberJackClientImpl - Class in org.thales.punch.netty.impl
This client is in charge of sending outgoing data to a lumberjack peer.
NettyLumberJackClientImpl(ISettingsMap, IMetricContext, NettyDataAcker) - Constructor for class org.thales.punch.netty.impl.NettyLumberJackClientImpl
Return a new NettyLumberJackTcpClient.
NettyLumberJackClientRunner - Class in org.thales.punch.netty.impl
This runner is in charge of running the main client lumberjack thread.
NettyLumberJackClientRunner(NettyLumberJackClientImpl, NettyDataAcker, ISettingsMap, NettyLumberjackEncoder, NettyLumberjackDecoder, Counter, Histogram) - Constructor for class org.thales.punch.netty.impl.NettyLumberJackClientRunner
Ctor
NettyLumberjackData - Class in org.thales.punch.netty.impl
 
NettyLumberjackDecoder - Class in org.thales.punch.netty.impl
This class is a slight facade on top of the plain LimberjackDecoder.
NettyLumberjackDecoder() - Constructor for class org.thales.punch.netty.impl.NettyLumberjackDecoder
Test constructor.
NettyLumberjackDecoder(IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyLumberjackDecoder
Ctor
NettyLumberjackEncoder - Class in org.thales.punch.netty.impl
 
NettyLumberjackEncoder(boolean) - Constructor for class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
NettyLumberjackPeerContext - Class in org.thales.punch.netty.impl
Each lumberjack peer is associated to an instance of this class.
NettyLumberJackServerImpl - Class in org.thales.punch.netty.impl
 
NettyLumberJackServerImpl(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyLumberJackServerImpl
Create a new single-threaded asynchronous TCP server.
NettyLumberJackTuple - Class in org.thales.punch.netty.impl
The tuple variant that embeds the content of a data lumberjack frame.
NettyLumberJackTuple(LumberjackFrame, ChannelHandlerContext, boolean) - Constructor for class org.thales.punch.netty.impl.NettyLumberJackTuple
 
NettyLumberJackTupleEmpty - Class in org.thales.punch.netty.impl
 
NettyLumberJackTupleEmpty(Map<String, String>) - Constructor for class org.thales.punch.netty.impl.NettyLumberJackTupleEmpty
 
NettyNetflowDecoder - Class in org.thales.punch.libraries.commons.netty.codec
This decoder transforms a Netflow packet into a sequence of netflow Json string.
NettyNetflowDecoder(int, IMetricContext) - Constructor for class org.thales.punch.libraries.commons.netty.codec.NettyNetflowDecoder
Watch out : the capacity parameter is a fixed capacity.
NettyNetflowEncoder - Class in org.thales.punch.libraries.commons.netty.codec
This encoder is useful to send test netflow frames.
NettyNetflowEncoder() - Constructor for class org.thales.punch.libraries.commons.netty.codec.NettyNetflowEncoder
 
NettyReaderByteBufCallback - Interface in org.thales.punch.netty.impl
Called when a NettySocketServer has received data.
NettyRelpDataHandler - Class in org.thales.punch.netty.relp.impl
Relp handler.
NettyRelpDataHandler(INettyReaderCallback<RELPFrame>, boolean) - Constructor for class org.thales.punch.netty.relp.impl.NettyRelpDataHandler
Ctor
NettyRelpServerImpl - Class in org.thales.punch.netty.relp.impl
An extra simple Netty TCP server, reading lines from a TCP socket.
NettyRelpServerImpl(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.relp.impl.NettyRelpServerImpl
Create a new single-threaded asynchronous TCP server.
NettyRelpTuple - Class in org.thales.punch.netty.relp.impl
A tuple containing a RELP frame.
NettyRelpTuple(RELPFrame, ChannelHandlerContext, RELPEncoder) - Constructor for class org.thales.punch.netty.relp.impl.NettyRelpTuple
Ctor
NettyServerDataHandler<T> - Class in org.thales.punch.netty.impl
This generic handler only deals with SSL end of negotiation, and once established, forward the received data to the user.
NettyServerDataHandler(INettyReaderCallback<T>, boolean) - Constructor for class org.thales.punch.netty.impl.NettyServerDataHandler
Ctor.
NettySnmpDecoder - Class in org.thales.punch.libraries.commons.netty.codec
This decoder transforms a Snmp packet into Json String.
NettySnmpDecoder() - Constructor for class org.thales.punch.libraries.commons.netty.codec.NettySnmpDecoder
 
NettySocketServer<T> - Interface in org.thales.punch.netty.api
Punch netty socket server interface.
NettyTcpClient<T> - Interface in org.thales.punch.netty.api
The Netty tcp client simply sends data to a tcp server.
NettyTcpClientImpl - Class in org.thales.punch.netty.impl
The NIO client sends out events as string on a tcp socket.
NettyTcpClientImpl(ISettingsMap, IMetricContext, NettyDataAcker) - Constructor for class org.thales.punch.netty.impl.NettyTcpClientImpl
Return a new NettyTcpClient.
NettyTcpClientImpl.Item - Class in org.thales.punch.netty.impl
 
NettyTcpServerImpl<T> - Class in org.thales.punch.netty.impl
An extra simple Netty TCP server, reading lines from a TCP socket.
NettyTcpServerImpl(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyTcpServerImpl
Create a new single-threaded asynchronous TCP server.
NettyTupleImpl<T> - Class in org.thales.punch.netty.impl
The basic single value tuple implementation.
NettyTupleImpl(T, InetSocketAddress, InetSocketAddress) - Constructor for class org.thales.punch.netty.impl.NettyTupleImpl
Create a NettyTuple to be notified to a receiver.
NettyUdpBytesDataHandler - Class in org.thales.punch.netty.impl
This handler simply pass the binary data as is to the receiver.
NettyUdpBytesDataHandler(INettyReaderCallback<byte[]>) - Constructor for class org.thales.punch.netty.impl.NettyUdpBytesDataHandler
 
NettyUdpByteToStringDataHandler - Class in org.thales.punch.netty.impl
This handler leverage a decoder that transforms input binary data into strings.
NettyUdpByteToStringDataHandler(INettyReaderCallback<String>, NettyCodec) - Constructor for class org.thales.punch.netty.impl.NettyUdpByteToStringDataHandler
 
NettyUdpClient - Interface in org.thales.punch.netty.api
The Netty tcp client simply sends string to a tcp server.
NettyUdpClientImpl - Class in org.thales.punch.netty.api
 
NettyUdpClientImpl(String, int) - Constructor for class org.thales.punch.netty.api.NettyUdpClientImpl
 
NettyUdpClientImpl(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.api.NettyUdpClientImpl
 
NettyUdpDataHandler - Class in org.thales.punch.netty.impl
 
NettyUdpDataHandler(INettyReaderCallback<String>) - Constructor for class org.thales.punch.netty.impl.NettyUdpDataHandler
 
NettyUdpServerImpl<T> - Class in org.thales.punch.netty.impl
An extra simple Netty UDP server
NettyUdpServerImpl(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.NettyUdpServerImpl
Create a new single-threaded asynchronous TCP server.

O

ok(long) - Static method in class org.thales.punch.netty.relp.proto.RELPResponse
Utility method to create a default "OK" response.
OK_CODE - Static variable in class org.thales.punch.netty.relp.proto.RELPResponse
 
onActive(ChannelHandlerContext) - Method in interface org.thales.punch.netty.api.INettyReaderCallback
You have the option to be told upon the activation of a peer.
onConnected(NettyAbstractClient) - Method in class org.thales.punch.libraries.netty.groups.Destination
 
onConnected(NettyAbstractClient) - Method in interface org.thales.punch.netty.api.INettyConnectionCallback
Connection callback.
onDisconnected(NettyAbstractClient, Throwable) - Method in class org.thales.punch.libraries.netty.groups.Destination
 
onDisconnected(NettyAbstractClient, Throwable) - Method in interface org.thales.punch.netty.api.INettyConnectionCallback
Disconnection callback.
onDisconnected(Throwable) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
 
onInactive(ChannelHandlerContext) - Method in interface org.thales.punch.netty.api.INettyReaderCallback
You have the option to be told upon the closing of the peer.
onReceive(ChannelHandlerContext, INettyTuple<T>) - Method in interface org.thales.punch.netty.api.INettyReaderCallback
Called when a NettySocketServer has received data.
onReceive(ChannelHandlerContext, INettyTuple<Map<String, Object>>) - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
Called when the underlying client has received some data from the server Do nothing now.
onReceive(ChannelHandlerContext, INettyTuple<Map<String, Object>>) - Method in class org.thales.punch.netty.impl.NettyHttpServerImpl
 
onReceive(ChannelHandlerContext, ByteBuf, Counter, Counter) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
Called when the underlying client has received some data from the server
onReceive(Channel, ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientRunner
 
onReceive(ChannelHandlerContext, ByteBuf, Counter, Counter) - Method in class org.thales.punch.netty.impl.NettyLumberJackServerImpl
 
onReceive(ChannelHandlerContext, ByteBuf, Counter, Counter) - Method in interface org.thales.punch.netty.impl.NettyReaderByteBufCallback
Called when a NettySocketServer has received data.
onReceive(ChannelHandlerContext, INettyTuple<String>) - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
onReceive(RELPClient, RELPFrame) - Method in interface org.thales.punch.netty.relp.proto.IRELPClientCallback
 
onReceive(RELPClient, RELPFrame) - Method in interface org.thales.punch.netty.relp.utils.IRELPClientCallback
 
onThrowable(Throwable) - Method in interface org.thales.punch.netty.api.INettyReaderCallback
You have the option to catch underlying exception thrown by netty, such as SSL exceptions.
open() - Method in class org.thales.punch.netty.relp.proto.RELPClient
Open the client, this triggers the relp open acknowledgment
open(long, Map<String, String>) - Static method in class org.thales.punch.netty.relp.proto.RELPResponse
Utility method to create a response to an open request.
open() - Method in class org.thales.punch.netty.relp.utils.RELPClient
Open the client, this triggers the relp open acknowledgment
org.thales.punch.libraries.commons.cli - package org.thales.punch.libraries.commons.cli
 
org.thales.punch.libraries.commons.netty.codec - package org.thales.punch.libraries.commons.netty.codec
 
org.thales.punch.libraries.netty.groups - package org.thales.punch.libraries.netty.groups
Socket destination group api.
org.thales.punch.libraries.netty.loadcontrol - package org.thales.punch.libraries.netty.loadcontrol
Rate limiter library.
org.thales.punch.netty.api - package org.thales.punch.netty.api
Copyright © 2016-2021 Thales Services Numériques Licensed under the Thales Inner Source Software License: Version 1.2, InnerOpen - Distribution Controlled You may not use this file except in compliance with the License.
org.thales.punch.netty.handler.codec - package org.thales.punch.netty.handler.codec
 
org.thales.punch.netty.impl - package org.thales.punch.netty.impl
 
org.thales.punch.netty.loggers - package org.thales.punch.netty.loggers
 
org.thales.punch.netty.relp.impl - package org.thales.punch.netty.relp.impl
 
org.thales.punch.netty.relp.proto - package org.thales.punch.netty.relp.proto
 
org.thales.punch.netty.relp.utils - package org.thales.punch.netty.relp.utils
 
org.thales.punch.snmp - package org.thales.punch.snmp
 

P

parseOffers(byte[], Charset) - Static method in class org.thales.punch.netty.relp.proto.RELPResponse
Parses the provided data into a Map of offers.
PeriodicLoggerWrapper - Class in org.thales.punch.netty.loggers
Log4j logger wrapper to limit logs in time
port - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
The listening or destination port
prepareAckFrame(int, byte) - Static method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
Allocate and create a new ack frame with the corresponding sequence number
prepareCompressFrame(ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
If compression is enable return a compressed frame.
prepareCompressFrame(ByteBuf[]) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
Get a compressed frame out a several data frame.
prepareDataFrame(String, int) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
prepareDataFrame(Map<String, String>, int) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
prepareKeepAliveFrame() - Static method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
printUsage() - Method in class org.thales.punch.libraries.commons.cli.CliCommand
 
process(byte) - Method in class org.thales.punch.netty.relp.proto.RELPDecoder
Process the next byte from the channel, updating the builder and state accordingly.
processPdu(CommandResponderEvent) - Method in class org.thales.punch.netty.impl.SnmpServerImpl
 
PROTO_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
protocol - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
The listening or destination host host ip address.

R

RateLimiterLoadController - Class in org.thales.punch.libraries.netty.loadcontrol
This class allows you to know when you should start refuse traffic because the application is overloaded.
RateLimiterLoadController(IMetricContext) - Constructor for class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
Create a new load controller with the default starting response time (RTT) of 30000, i.e.
raw - Variable in class org.thales.punch.netty.impl.NettyAbstractClient
dont add any '\n' at the end of Strings
RAW_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
READ_SOCKET_TIMEOUT_ACTION_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
READ_SOCKET_TIMEOUT_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
readSocketTimeoutAction - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
what to do if the timeout occurs
readSocketTimeoutAction - Variable in class org.thales.punch.netty.impl.NettyInitializer
what to do if the timeout occurs.
readSocketTimeoutMs - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
timeout if no data is read for this amount of seconds
readSocketTimeoutMs - Variable in class org.thales.punch.netty.impl.NettyInitializer
automatically do something if no data is read
readSslFile(String) - Static method in class org.thales.punch.netty.impl.NettyConfig
 
receivedKeepAliveAck() - Method in class org.thales.punch.netty.impl.NettyLumberjackPeerContext
 
refreshKeepAlive() - Method in class org.thales.punch.netty.impl.NettyLumberjackPeerContext
 
registerSubcommand(String, CliCommand) - Method in class org.thales.punch.libraries.commons.cli.CommandLineRunner
Registers a new sub command.
regulate() - Method in interface org.thales.punch.libraries.netty.loadcontrol.ILoadController
regulate the traffic, this method potentially take some time before returning.
regulate() - Method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
 
regulate() - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
 
RELPClient - Class in org.thales.punch.netty.relp.proto
As simple Relp client.
RELPClient(String, int) - Constructor for class org.thales.punch.netty.relp.proto.RELPClient
Ctor
RELPClient - Class in org.thales.punch.netty.relp.utils
As simple Relp client.
RELPClient(String, int) - Constructor for class org.thales.punch.netty.relp.utils.RELPClient
Ctor
RELPDecoder - Class in org.thales.punch.netty.relp.proto
Decodes a RELP frame by maintaining a state based on each byte that has been processed.
RELPDecoder(Charset) - Constructor for class org.thales.punch.netty.relp.proto.RELPDecoder
 
RELPDecoder(Charset, ByteArrayOutputStream) - Constructor for class org.thales.punch.netty.relp.proto.RELPDecoder
 
RELPEncoder - Class in org.thales.punch.netty.relp.proto
Encodes a RELPFrame into raw bytes using the given charset.
RELPEncoder(Charset) - Constructor for class org.thales.punch.netty.relp.proto.RELPEncoder
 
RELPFrame - Class in org.thales.punch.netty.relp.proto
A RELP frame received from a channel.
RELPFrame.Builder - Class in org.thales.punch.netty.relp.proto
Builder for a RELPFrame.
RelpFrameDecoder - Class in org.thales.punch.netty.handler.codec
A relp decoder.
RelpFrameDecoder(Charset, int) - Constructor for class org.thales.punch.netty.handler.codec.RelpFrameDecoder
Creates a new instance.
RELPFrameException - Exception in org.thales.punch.netty.relp.proto
Represents an error encountered when decoding RELP frames.
RELPFrameException(String) - Constructor for exception org.thales.punch.netty.relp.proto.RELPFrameException
 
RELPFrameException(String, Throwable) - Constructor for exception org.thales.punch.netty.relp.proto.RELPFrameException
 
RELPResponse - Class in org.thales.punch.netty.relp.proto
The data portion of a RELPFrame for a response: RSP-CODE [SP HUMANMSG] LF [CMDDATA]
RELPResponse(long, int) - Constructor for class org.thales.punch.netty.relp.proto.RELPResponse
 
RELPResponse(long, int, String, String) - Constructor for class org.thales.punch.netty.relp.proto.RELPResponse
 
RELPState - Enum in org.thales.punch.netty.relp.proto
The parts of a RELP frame.
remove(Destination<T>) - Method in class org.thales.punch.libraries.netty.groups.DestinationLoadBalancer
Remove a destination to this load bamancer
reset() - Method in class org.thales.punch.netty.relp.proto.RELPDecoder
Resets this decoder back to it's initial state.
reset() - Method in class org.thales.punch.netty.relp.proto.RELPFrame.Builder
 
RSP_CMD - Static variable in class org.thales.punch.netty.relp.proto.RELPResponse
 
run() - Method in class org.thales.punch.libraries.commons.cli.CliCommand
The actual execution of the command if all required parameters are here.
run() - Method in interface org.thales.punch.netty.api.NettySocketServer
Effectively runs the server.
run() - Method in class org.thales.punch.netty.impl.NettyHttpServerImpl
 
run() - Method in class org.thales.punch.netty.impl.NettyLumberJackClientRunner
 
run() - Method in class org.thales.punch.netty.impl.NettyLumberjackPeerContext
 
run() - Method in class org.thales.punch.netty.impl.NettyLumberJackServerImpl
 
run() - Method in class org.thales.punch.netty.impl.NettyTcpServerImpl
 
run() - Method in class org.thales.punch.netty.impl.NettyUdpServerImpl
 
run() - Method in class org.thales.punch.netty.impl.SnmpServerImpl
Our contract is to not return until we are stopped.
run() - Method in class org.thales.punch.netty.relp.impl.NettyRelpServerImpl
 
runOrHelp(JCommander) - Method in class org.thales.punch.libraries.commons.cli.CliCommand
This is called from the CommandLineRunner.
runOrHelp(String, String[]) - Method in class org.thales.punch.libraries.commons.cli.CommandLineRunner
 
runServer(NettySocketServer<?>, String) - Static method in class org.thales.punch.netty.api.UtilNettyServer
Start a netty server in a dedicated thread.

S

send(long, String) - Method in class org.thales.punch.netty.relp.proto.RELPClient
Send a string payload
send(long, byte[]) - Method in class org.thales.punch.netty.relp.proto.RELPClient
Send a byte array payload
send(long, String) - Method in class org.thales.punch.netty.relp.utils.RELPClient
Send a string payload
send(long, byte[]) - Method in class org.thales.punch.netty.relp.utils.RELPClient
Send a byte array payload
SEPARATOR - Static variable in class org.thales.punch.netty.relp.proto.RELPFrame
 
setAdaptative(Boolean) - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
activate an adaptative load control.
setCallback(INettyReaderCallback<T>) - Method in interface org.thales.punch.netty.api.NettySocketServer
 
setCallback(INettyReaderCallback<Map<String, Object>>) - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
setCallback(INettyReaderCallback<Map<String, Object>>) - Method in class org.thales.punch.netty.impl.NettyHttpServerImpl
 
setCallback(INettyReaderCallback<Map<String, String>>) - Method in class org.thales.punch.netty.impl.NettyLumberJackServerImpl
 
setCallback(INettyReaderCallback<T>) - Method in class org.thales.punch.netty.impl.NettyTcpServerImpl
 
setCallback(INettyReaderCallback<T>) - Method in class org.thales.punch.netty.impl.NettyUdpServerImpl
 
setCallback(INettyReaderCallback<String>) - Method in class org.thales.punch.netty.impl.SnmpServerImpl
Set the user callback to send him Netty Tuple containing a Json representation of SNMP traps.
setCallback(INettyReaderCallback<RELPFrame>) - Method in class org.thales.punch.netty.relp.impl.NettyRelpServerImpl
 
setCallback(IRELPClientCallback) - Method in class org.thales.punch.netty.relp.proto.RELPClient
 
setCallback(IRELPClientCallback) - Method in class org.thales.punch.netty.relp.utils.RELPClient
 
setCodec(String) - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
setConnectIntervalMs(long) - Method in class org.thales.punch.netty.impl.NettyAbstractClient
Set the connection interval
setConnectionCallback(INettyConnectionCallback) - Method in interface org.thales.punch.netty.api.NettyTcpClient
Request to be told upon connection/disconnection with the target server.
setConnectionCallback(INettyConnectionCallback) - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
setConnectionCallback(INettyConnectionCallback) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
 
setConnectionCallback(INettyConnectionCallback) - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
setConnectRetryIntervalMs(long) - Method in class org.thales.punch.netty.impl.NettyAbstractClient
Set the connection retry interval
setDirectResponse(boolean) - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
setFuture(ScheduledFuture<?>) - Method in class org.thales.punch.netty.impl.NettyLumberjackPeerContext
 
setHttpCompressed(boolean) - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
setKeepAlive(boolean) - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
setLumberjackCompressed(boolean) - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
setMaxTimeoutSec(int) - Method in interface org.thales.punch.libraries.netty.loadcontrol.ILoadController
Set the time considered as the maximum traversal time.
setMaxTimeoutSec(int) - Method in class org.thales.punch.libraries.netty.loadcontrol.LoadController
 
setName(String) - Method in interface org.thales.punch.netty.api.NettyTcpClient
Associate a name to the client.
setName(String) - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
setName(String) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
 
setName(String) - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
setRate(long) - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
Set the rate expressed in eps
setStartupTimeout(long) - Method in class org.thales.punch.libraries.netty.groups.Groups
Set a startup timeout
setStatsDelay(long) - Method in class org.thales.punch.libraries.netty.loadcontrol.RateLimiterLoadController
set the stats publishing delay
setUniqueID(String) - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
setWaitConnectionsTimeout(long) - Method in class org.thales.punch.libraries.netty.groups.Groups
Set a wait connection timeout
shutdown() - Method in class org.thales.punch.netty.impl.NettyAbstractClient
 
SnmpServerImpl - Class in org.thales.punch.netty.impl
SNMP endpoint.
SnmpServerImpl(ISettingsMap, IMetricContext) - Constructor for class org.thales.punch.netty.impl.SnmpServerImpl
Create a new SNMP server.
SNMPValue - Class in org.thales.punch.snmp
This class encapsulates a SNMP4J value of an SNMP variable, for the purpose on converting it to a Json representation, with separate fields for description of the type, and for the value.
SNMPValue(Variable) - Constructor for class org.thales.punch.snmp.SNMPValue
 
SNMPValueType - Enum in org.thales.punch.snmp
This type provides the mapping between SNMP4J SMI types and their Json representation when decoded by the PunchPlatform SNMPSpout.
ssl - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
use ssl.
SSL_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
SSL_PROTOCOL_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
SSL_PROVIDER_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
SSL_STRICT_CLIENT_AUTHENTICATION_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
sslCiphers - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
default ciphers used by endpoints
sslCtx - Variable in class org.thales.punch.netty.impl.NettyAbstractServer
 
sslCtx - Variable in class org.thales.punch.netty.impl.NettyInitializer
ssl context if enabled
sslProtocol - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
protocol to use for ssl
sslProvider - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
ssl provider to use : JDK, OPENSSL or OPENSSL_REFCNT
sslSessionResumption - Variable in class org.thales.punch.netty.impl.NettyAbstractServer
 
start() - Method in class org.thales.punch.libraries.netty.groups.Destination
start this destination.
start() - Method in class org.thales.punch.libraries.netty.groups.Group
Start this group.
start(long, long) - Method in class org.thales.punch.libraries.netty.groups.Groups
Start the groups of destination.
start() - Method in class org.thales.punch.libraries.netty.groups.Groups
Start the group
start() - Method in interface org.thales.punch.netty.api.NettyTcpClient
Start the client.
start() - Method in class org.thales.punch.netty.impl.NettyAbstractServer
 
start() - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
start() - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
Start the client.
start() - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
startDataFrame(int, ByteBuf) - Method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
 
STARTUP_CONNECTION_TIMEOUT_KEY - Static variable in class org.thales.punch.libraries.netty.groups.GroupConfig
give some time for the initial connections to be setup.
startWithNumeric(ByteBuf) - Static method in class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
 
statsDelay - Variable in class org.thales.punch.libraries.netty.loadcontrol.LoadController
 
stop() - Method in class org.thales.punch.libraries.netty.groups.Destination
Stop and shutdown this destination.
stop() - Method in class org.thales.punch.libraries.netty.groups.Group
Stop this group
stop() - Method in class org.thales.punch.libraries.netty.groups.Groups
Stop all the groups
stop() - Method in interface org.thales.punch.netty.api.NettySocketServer
Stop the server.
stop() - Method in interface org.thales.punch.netty.api.NettyTcpClient
Stop the client.
stop() - Method in class org.thales.punch.netty.impl.NettyAbstractServer
Stop the server, close all the socket.
stop() - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
stop() - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
 
stop() - Method in class org.thales.punch.netty.impl.NettyLumberJackClientRunner
 
stop() - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
stop() - Method in class org.thales.punch.netty.impl.NettyUdpServerImpl
 
stop() - Method in class org.thales.punch.netty.impl.SnmpServerImpl
Stop the server.
SyslogAutoOctetOrEolFrameDecoder - Class in org.thales.punch.netty.handler.codec
This decoder ic capable of detecting on the same received buffer an mix of octet-counting or end-of-line SYSLOG messages.
SyslogAutoOctetOrEolFrameDecoder(int, ByteBuf) - Constructor for class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
Creates a new instance.
SyslogAutoOctetOrEolFrameDecoder(int, boolean, ByteBuf) - Constructor for class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
Creates a new instance.
SyslogAutoOctetOrEolFrameDecoder(int, boolean, boolean, ByteBuf) - Constructor for class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
Creates a new instance.
SyslogAutoOctetOrEolFrameDecoder(int, ByteBuf...) - Constructor for class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
Creates a new instance.
SyslogAutoOctetOrEolFrameDecoder(int, boolean, ByteBuf...) - Constructor for class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
Creates a new instance.
SyslogAutoOctetOrEolFrameDecoder(int, boolean, boolean, ByteBuf...) - Constructor for class org.thales.punch.netty.handler.codec.SyslogAutoOctetOrEolFrameDecoder
Creates a new instance.
SyslogOctetCountFrameDecoder - Class in org.thales.punch.netty.handler.codec
Implements a Netty ByteToMessageDecoder for the Syslog octet counting framing.
SyslogOctetCountFrameDecoder() - Constructor for class org.thales.punch.netty.handler.codec.SyslogOctetCountFrameDecoder
 

T

toByteArray(ByteBuf) - Static method in class org.thales.punch.netty.impl.NettyLumberjackEncoder
Convert a ByteBuf to a byte array.
toByteBuf(byte[]) - Static method in class org.thales.punch.netty.api.UtilNettyByteBuf
 
toByteBuf(byte[]) - Static method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
toFrame(Charset) - Method in class org.thales.punch.netty.relp.proto.RELPResponse
Creates a RELPFrame where the data portion will contain this response.
toIpv4(int) - Static method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowDecoder
 
toIpv4(String) - Static method in class org.thales.punch.libraries.commons.netty.codec.NettyNetflowDecoder
 
toJson(PDU) - Method in class org.thales.punch.libraries.commons.netty.codec.NettySnmpDecoder
 
toString() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowField
 
toString() - Method in class org.thales.punch.libraries.commons.netty.codec.NetflowScope
 
toString() - Method in class org.thales.punch.libraries.netty.groups.Destination
 
toString() - Method in class org.thales.punch.libraries.netty.groups.Group
 
toString() - Method in class org.thales.punch.netty.api.NettyEndPointAddress
 
toString() - Method in class org.thales.punch.netty.impl.NettyHttpServerImpl
 
toString() - Method in class org.thales.punch.netty.impl.NettyHttpTuple
 
toString() - Method in class org.thales.punch.netty.impl.NettyHttpTupleEmpty
 
toString() - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
 
toString() - Method in class org.thales.punch.netty.impl.NettyLumberjackData
 
toString() - Method in class org.thales.punch.netty.impl.NettyLumberJackServerImpl
 
toString() - Method in class org.thales.punch.netty.impl.NettyLumberJackTuple
 
toString() - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl.Item
 
toString() - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
 
toString() - Method in class org.thales.punch.netty.impl.NettyTcpServerImpl
 
toString() - Method in class org.thales.punch.netty.impl.NettyTupleImpl
 
toString() - Method in class org.thales.punch.netty.impl.NettyUdpServerImpl
 
toString() - Method in class org.thales.punch.netty.impl.SnmpServerImpl
 
toString() - Method in class org.thales.punch.netty.relp.impl.NettyRelpServerImpl
 
toString() - Method in class org.thales.punch.netty.relp.impl.NettyRelpTuple
 
trace(String, byte[], int) - Static method in class org.thales.punch.netty.impl.MonitoringHandler
trace a useful hex dump of some received or written traffic
trace(String, Object...) - Method in class org.thales.punch.netty.loggers.PeriodicLoggerWrapper
 
txnr(long) - Method in class org.thales.punch.netty.relp.proto.RELPFrame.Builder
 
typeOfSMISyntax(int) - Static method in enum org.thales.punch.snmp.SNMPValueType
 

U

UDP_MAX_PAYLOAD_LENGTH_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
UDP_RECV_BUFFER_SIZE_DEFAULT_VALUE - Static variable in class org.thales.punch.netty.impl.NettyConfig
 
UdpTable - Class in org.thales.punch.netty.impl
UDP Table basic parser
UdpTable(List<String>) - Constructor for class org.thales.punch.netty.impl.UdpTable
 
UdpTable.Builder - Class in org.thales.punch.netty.impl
Builder for UDPTable class
UdpTable.Host - Class in org.thales.punch.netty.impl
Manage a host as written in UDP Socket
UdpTable.Socket - Class in org.thales.punch.netty.impl
This class corresponds to a line in UDP Socket table
update() - Method in class org.thales.punch.libraries.netty.groups.Groups
This method is called whenver a destination to any of the group joins or leaves.
useNettyCompression - Variable in class org.thales.punch.netty.impl.NettyAbstractEndpoint
use compression at the socket level
useNettyCompression - Variable in class org.thales.punch.netty.impl.NettyInitializer
turn on/off netty level compression
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
userEventTriggered(ChannelHandlerContext, Object) - Method in class org.thales.punch.netty.impl.NettyClientByteBufDataHandlerHandler
 
UtilNettyByteBuf - Class in org.thales.punch.netty.api
Utility
UtilNettyByteBuf() - Constructor for class org.thales.punch.netty.api.UtilNettyByteBuf
 
UtilNettyServer - Class in org.thales.punch.netty.api
A utility class to start simple servers.
UtilNettyValueGetter<T> - Class in org.thales.punch.netty.api
This class efficiently returns a list of values to be emitted in the pipeline.
UtilNettyValueGetter(List<String>, String, String, INettyTupleValueGetter<T>) - Constructor for class org.thales.punch.netty.api.UtilNettyValueGetter
 

V

valueOf(String) - Static method in enum org.thales.punch.libraries.commons.netty.codec.NetflowElement.Type
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.thales.punch.netty.relp.proto.RELPState
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.thales.punch.snmp.SNMPValueType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.thales.punch.libraries.commons.netty.codec.NetflowElement.Type
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.thales.punch.netty.relp.proto.RELPState
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.thales.punch.snmp.SNMPValueType
Returns an array containing the constants of this enum type, in the order they are declared.

W

warn(String, Object...) - Method in class org.thales.punch.netty.loggers.PeriodicLoggerWrapper
 
workerGroup - Variable in class org.thales.punch.netty.impl.NettyAbstractServer
 
write(T, Object) - Method in class org.thales.punch.libraries.netty.groups.Group
Write a packet to one of the destination available in a group.
write(T, Object) - Method in class org.thales.punch.libraries.netty.groups.Groups
Write a packet of data to one of the group destination.
write(T) - Method in interface org.thales.punch.netty.api.NettyTcpClient
Write some line of data to the server.
write(T, Object) - Method in interface org.thales.punch.netty.api.NettyTcpClient
Write some line of data to the server using an acknowledgement mode.
write(String) - Method in interface org.thales.punch.netty.api.NettyUdpClient
Write some line of data to the server.
write(byte[]) - Method in interface org.thales.punch.netty.api.NettyUdpClient
Write some line of data to the server.
write(String) - Method in class org.thales.punch.netty.api.NettyUdpClientImpl
 
write(byte[]) - Method in class org.thales.punch.netty.api.NettyUdpClientImpl
 
write(ChannelHandlerContext, Object, ChannelPromise) - Method in class org.thales.punch.netty.impl.MonitoringHandler
 
write(String) - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
write(String, Object) - Method in class org.thales.punch.netty.impl.NettyHttpClientImpl
 
write(Map<String, String>) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
 
write(Map<String, String>, Object) - Method in class org.thales.punch.netty.impl.NettyLumberJackClientImpl
 
write(String) - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
Write some data to the server.
write(String, Object) - Method in class org.thales.punch.netty.impl.NettyTcpClientImpl
Write some data to the server.
A B C D E F G H I J K L M N O P R S T U V W 
Skip navigation links

Copyright © 2023. All rights reserved.