org.graylog2.inputs.codecs

Class GelfChunkAggregator

java.lang.Object

org.graylog2.inputs.codecs.GelfChunkAggregator

All Implemented Interfaces:

CodecAggregator

public class GelfChunkAggregator
extends Object
implements CodecAggregator

Nested Class Summary

Nested classes/interfaces inherited from interface org.graylog2.plugin.inputs.codecs.CodecAggregator

CodecAggregator.Result

Field Summary

Fields

Modifier and Type	Field and Description
static String	CHUNK_COUNTER
static String	COMPLETE_MESSAGES
static String	EXPIRED_CHUNKS
static String	EXPIRED_MESSAGES
static CodecAggregator.Result	INVALID_RESULT
static CodecAggregator.Result	VALID_EMPTY_RESULT
static int	VALIDITY_PERIOD
static String	WAITING_MESSAGES

Constructor Summary

Constructors

Constructor and Description
GelfChunkAggregator(ScheduledExecutorService scheduler, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Methods

Modifier and Type	Method and Description
CodecAggregator.Result	addChunk(org.jboss.netty.buffer.ChannelBuffer buffer)

Methods inherited from class java.lang.Object

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

Field Detail

VALID_EMPTY_RESULT

public static final CodecAggregator.Result VALID_EMPTY_RESULT

INVALID_RESULT

public static final CodecAggregator.Result INVALID_RESULT

VALIDITY_PERIOD

public static final int VALIDITY_PERIOD

See Also:

Constant Field Values

CHUNK_COUNTER

public static final String CHUNK_COUNTER

WAITING_MESSAGES

public static final String WAITING_MESSAGES

COMPLETE_MESSAGES

public static final String COMPLETE_MESSAGES

EXPIRED_MESSAGES

public static final String EXPIRED_MESSAGES

EXPIRED_CHUNKS

public static final String EXPIRED_CHUNKS

Constructor Detail

GelfChunkAggregator

@Inject
public GelfChunkAggregator(@Named(value="daemonScheduler")
                          ScheduledExecutorService scheduler,
                          com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

addChunk

@Nonnull
public CodecAggregator.Result addChunk(org.jboss.netty.buffer.ChannelBuffer buffer)

Specified by:

addChunk in interface CodecAggregator