| Constructor and Description |
|---|
MessageFilterChainProcessor(com.codahale.metrics.MetricRegistry metricRegistry,
Set<MessageFilter> filterRegistry,
Journal journal,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
BenchmarkOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Journal journal) |
BenchmarkOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Journal journal,
Stream stream,
Configuration configuration) |
BlockingBatchedESOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Messages messages,
Cluster cluster,
Configuration serverConfiguration,
Journal journal) |
BlockingBatchedESOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Messages messages,
Cluster cluster,
Configuration serverConfiguration,
Journal journal,
Stream stream,
Configuration configuration) |
DiscardMessageOutput(Journal journal,
com.codahale.metrics.MetricRegistry metricRegistry) |
DiscardMessageOutput(Journal journal,
com.codahale.metrics.MetricRegistry metricRegistry,
Stream stream,
Configuration configuration) |
ElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Messages messages,
Journal journal) |
ElasticSearchOutput(com.codahale.metrics.MetricRegistry metricRegistry,
Messages messages,
Journal journal,
Stream stream,
Configuration configuration) |
| Constructor and Description |
|---|
ThrottleStateUpdaterThread(Journal journal,
ProcessBuffer processBuffer,
com.google.common.eventbus.EventBus eventBus,
NotificationService notificationService,
ServerStatus serverStatus,
com.codahale.metrics.MetricRegistry metricRegistry,
com.github.joschi.jadconfig.util.Size retentionSize) |
| Constructor and Description |
|---|
JournalResource(Configuration configuration,
KafkaJournalConfiguration kafkaJournalConfiguration,
Journal journal) |
| Constructor and Description |
|---|
JournallingMessageHandler(com.codahale.metrics.MetricRegistry metrics,
Journal journal,
Semaphore journalFilled) |
| Constructor and Description |
|---|
DecodingProcessor(Map<String,Codec.Factory<? extends Codec>> codecFactory,
ServerStatus serverStatus,
com.codahale.metrics.MetricRegistry metricRegistry,
Journal journal,
com.codahale.metrics.Timer decodeTime,
com.codahale.metrics.Timer parseTime) |
| Modifier and Type | Class and Description |
|---|---|
class |
KafkaJournal |
class |
NoopJournal
NoopJournal is used when disk journalling is turned off.
|
| Constructor and Description |
|---|
JournalReader(Journal journal,
ProcessBuffer processBuffer,
Semaphore journalFilled,
com.codahale.metrics.MetricRegistry metricRegistry,
com.google.common.eventbus.EventBus eventBus) |
Copyright © 2012–2017 Graylog, Inc.. All rights reserved.