org.graylog2.plugin

Class KafkaJournalConfiguration

java.lang.Object

org.graylog2.configuration.PathConfiguration

org.graylog2.plugin.KafkaJournalConfiguration

public class KafkaJournalConfiguration
extends PathConfiguration

Constructor Summary

Constructors

Constructor and Description
KafkaJournalConfiguration()
KafkaJournalConfiguration(@NotNull Path messageJournalDir, long messageJournalSegmentSize, org.joda.time.Duration messageJournalSegmentAge, long messageJournalMaxSize, org.joda.time.Duration messageJournalMaxAge, long messageJournalFlushInterval, org.joda.time.Duration messageJournalFlushAge)

Method Summary

Modifier and Type	Method and Description
Path	getMessageJournalDir()
org.joda.time.Duration	getMessageJournalFlushAge()
long	getMessageJournalFlushInterval()
org.joda.time.Duration	getMessageJournalMaxAge()
com.github.joschi.jadconfig.util.Size	getMessageJournalMaxSize()
org.joda.time.Duration	getMessageJournalSegmentAge()
com.github.joschi.jadconfig.util.Size	getMessageJournalSegmentSize()

Methods inherited from class org.graylog2.configuration.PathConfiguration

getBinDir, getDataDir, getPluginDir

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaJournalConfiguration

public KafkaJournalConfiguration()

KafkaJournalConfiguration

public KafkaJournalConfiguration(@NotNull
                                 @NotNull Path messageJournalDir,
                                 long messageJournalSegmentSize,
                                 org.joda.time.Duration messageJournalSegmentAge,
                                 long messageJournalMaxSize,
                                 org.joda.time.Duration messageJournalMaxAge,
                                 long messageJournalFlushInterval,
                                 org.joda.time.Duration messageJournalFlushAge)

Method Detail

getMessageJournalDir

public Path getMessageJournalDir()

getMessageJournalSegmentSize

public com.github.joschi.jadconfig.util.Size getMessageJournalSegmentSize()

getMessageJournalSegmentAge

public org.joda.time.Duration getMessageJournalSegmentAge()

getMessageJournalMaxAge

public org.joda.time.Duration getMessageJournalMaxAge()

getMessageJournalMaxSize

public com.github.joschi.jadconfig.util.Size getMessageJournalMaxSize()

getMessageJournalFlushInterval

public long getMessageJournalFlushInterval()

getMessageJournalFlushAge

public org.joda.time.Duration getMessageJournalFlushAge()