org.graylog2.caches

Class DiskJournalCache

java.lang.Object

org.graylog2.caches.DiskJournalCache

All Implemented Interfaces:

Cache, InputCache, OutputCache

Direct Known Subclasses:

DiskJournalCache.Input, DiskJournalCache.Output

public abstract class DiskJournalCache
extends java.lang.Object
implements InputCache, OutputCache

Implements a Cache based on MapDB.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DiskJournalCache.Input
static class	DiskJournalCache.Output

Constructor Summary

Constructors

Constructor and Description
DiskJournalCache(Configuration config, MessageToJsonSerializer serializer, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
void	add(java.util.Collection<Message> m)
void	add(Message message)
int	drainTo(java.util.Collection<? super Message> c, int n)
protected abstract java.lang.String	getDbFileName()
boolean	isEmpty()
Message	pop()
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

DiskJournalCache

@Inject
public DiskJournalCache(Configuration config,
                                MessageToJsonSerializer serializer,
                                com.codahale.metrics.MetricRegistry metricRegistry)
                         throws java.io.IOException,
                                DiskJournalCacheCorruptSpoolException

Throws:

java.io.IOException

DiskJournalCacheCorruptSpoolException

Method Detail

add

public void add(Message message)

Specified by:

add in interface Cache

add

public void add(java.util.Collection<Message> m)

Specified by:

add in interface Cache

pop

public Message pop()

Specified by:

pop in interface Cache

drainTo

public int drainTo(java.util.Collection<? super Message> c,
                   int n)

Specified by:

drainTo in interface Cache

size

public int size()

Specified by:

size in interface Cache

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Cache

getDbFileName

protected abstract java.lang.String getDbFileName()