org.graylog2.buffers

Class OutputBuffer

java.lang.Object

org.graylog2.plugin.buffers.Buffer

org.graylog2.buffers.OutputBuffer

@Singleton
public class OutputBuffer
extends Buffer

Field Summary

Fields inherited from class org.graylog2.plugin.buffers.Buffer

ringBuffer

Constructor Summary

Constructors

Constructor and Description
OutputBuffer(OutputBufferProcessor.Factory outputBufferProcessorFactory, com.codahale.metrics.MetricRegistry metricRegistry, OutputBufferWatermark outputBufferWatermark, Configuration configuration, OutputCache overflowCache)

Method Summary

Modifier and Type	Method and Description
protected void	afterInsert(int n)
Cache	getOverflowCache()
void	initialize()
void	insertCached(java.util.List<Message> messages)
void	insertCached(Message message, MessageInput sourceInput)
void	insertFailFast(java.util.List<Message> messages)
void	insertFailFast(Message message, MessageInput sourceInput)

Methods inherited from class org.graylog2.plugin.buffers.Buffer

getUsage, hasCapacity, hasCapacity, insert, insert, isEmpty

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputBuffer

@Inject
public OutputBuffer(OutputBufferProcessor.Factory outputBufferProcessorFactory,
                            com.codahale.metrics.MetricRegistry metricRegistry,
                            OutputBufferWatermark outputBufferWatermark,
                            Configuration configuration,
                            OutputCache overflowCache)

Method Detail

getOverflowCache

public Cache getOverflowCache()

initialize

public void initialize()

insertCached

public void insertCached(Message message,
                         MessageInput sourceInput)

Specified by:

insertCached in class Buffer

insertFailFast

public void insertFailFast(Message message,
                           MessageInput sourceInput)
                    throws BufferOutOfCapacityException

Specified by:

insertFailFast in class Buffer

Throws:

BufferOutOfCapacityException

insertCached

public void insertCached(java.util.List<Message> messages)

Specified by:

insertCached in class Buffer

insertFailFast

public void insertFailFast(java.util.List<Message> messages)
                    throws BufferOutOfCapacityException

Specified by:

insertFailFast in class Buffer

Throws:

BufferOutOfCapacityException

afterInsert

protected void afterInsert(int n)

Specified by:

afterInsert in class Buffer