org.graylog2.inputs.transports

Class HttpTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.NettyTransport

org.graylog2.plugin.inputs.transports.AbstractTcpTransport

org.graylog2.inputs.transports.HttpTransport

All Implemented Interfaces:

Transport

public class HttpTransport
extends AbstractTcpTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HttpTransport.Config
static interface	HttpTransport.Factory

Field Summary

Fields

Modifier and Type	Field and Description
protected static int	DEFAULT_MAX_CHUNK_SIZE
protected boolean	enableBulkReceiving
protected boolean	enableCors
protected int	maxChunkSize

Fields inherited from class org.graylog2.plugin.inputs.transports.AbstractTcpTransport

childEventLoopGroup, configuration, parentEventLoopGroup

Fields inherited from class org.graylog2.plugin.inputs.transports.NettyTransport

CK_BIND_ADDRESS, CK_NUMBER_WORKER_THREADS, CK_PORT, CK_RECV_BUFFER_SIZE, eventLoopGroupFactory, localRegistry, socketAddress, throughputCounter, workerThreads

Constructor Summary

Constructors

Constructor and Description
HttpTransport(Configuration configuration, io.netty.channel.EventLoopGroup eventLoopGroup, EventLoopGroupFactory eventLoopGroupFactory, NettyTransportConfiguration nettyTransportConfiguration, ThroughputCounter throughputCounter, LocalMetricRegistry localRegistry, TLSProtocolsConfiguration tlsConfiguration)

Method Summary

Modifier and Type	Method and Description
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	getCustomChildChannelHandlers(MessageInput input) Subclasses can override this to modify the channel handlers at the end of the pipeline for child channels.
protected static int	parseMaxChunkSize(Configuration configuration)

Methods inherited from class org.graylog2.plugin.inputs.transports.AbstractTcpTransport

getBootstrap, getChildChannelHandlers, getLocalAddress, launch, stop

Methods inherited from class org.graylog2.plugin.inputs.transports.NettyTransport

getAggregator, getChannelHandlers, getChannelInitializer, getMetricSet, getRecvBufferSize, setMessageAggregator

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

DEFAULT_MAX_CHUNK_SIZE

protected static final int DEFAULT_MAX_CHUNK_SIZE

enableBulkReceiving

protected final boolean enableBulkReceiving

enableCors

protected final boolean enableCors

maxChunkSize

protected final int maxChunkSize

Constructor Detail

HttpTransport

public HttpTransport(Configuration configuration,
                     io.netty.channel.EventLoopGroup eventLoopGroup,
                     EventLoopGroupFactory eventLoopGroupFactory,
                     NettyTransportConfiguration nettyTransportConfiguration,
                     ThroughputCounter throughputCounter,
                     LocalMetricRegistry localRegistry,
                     TLSProtocolsConfiguration tlsConfiguration)

Method Detail

parseMaxChunkSize

protected static int parseMaxChunkSize(Configuration configuration)

Returns:

If the configured Max Chunk Size is less than zero, return DEFAULT_MAX_CHUNK_SIZE.

getCustomChildChannelHandlers

protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>> getCustomChildChannelHandlers(MessageInput input)

Description copied from class: NettyTransport

Subclasses can override this to modify the channel handlers at the end of the pipeline for child channels.

Overrides:

getCustomChildChannelHandlers in class NettyTransport

Parameters:

input - The MessageInput for which these child channel handlers are being added

Returns:

list of custom channel handlers to add to the Netty channel pipeline for child channels