| Constructor and Description |
|---|
Beats2Input(Configuration configuration,
BeatsTransport.Factory transportFactory,
Beats2Codec.Factory codecFactory,
Beats2Input.Config config,
Beats2Input.Descriptor descriptor,
com.codahale.metrics.MetricRegistry metricRegistry,
LocalMetricRegistry localRegistry,
ServerStatus serverStatus) |
BeatsInput(Configuration configuration,
BeatsTransport.Factory transportFactory,
BeatsCodec.Factory codecFactory,
BeatsInput.Config config,
BeatsInput.Descriptor descriptor,
com.codahale.metrics.MetricRegistry metricRegistry,
LocalMetricRegistry localRegistry,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
CEFAmqpInput(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
AmqpTransport.Factory amqpTransportFactory,
LocalMetricRegistry localRegistry,
CEFCodec.Factory codec,
CEFAmqpInput.Config config,
CEFAmqpInput.Descriptor descriptor,
ServerStatus serverStatus) |
CEFKafkaInput(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
KafkaTransport.Factory kafkaTransportFactory,
LocalMetricRegistry localRegistry,
CEFCodec.Factory codec,
CEFKafkaInput.Config config,
CEFKafkaInput.Descriptor descriptor,
ServerStatus serverStatus) |
CEFTCPInput(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
TcpTransport.Factory tcpTransportFactory,
LocalMetricRegistry localRegistry,
CEFCodec.Factory codec,
CEFTCPInput.Config config,
CEFTCPInput.Descriptor descriptor,
ServerStatus serverStatus) |
CEFUDPInput(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
UdpTransport.Factory udpTransportFactory,
LocalMetricRegistry localRegistry,
CEFCodec.Factory codec,
CEFUDPInput.Config config,
CEFUDPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
NetFlowUdpInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
NetFlowUdpTransport.Factory transportFactory,
NetFlowCodec.Factory codecFactory,
LocalMetricRegistry localMetricRegistry,
NetFlowUdpInput.Config config,
NetFlowUdpInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
BundleImporterProvider(InputService inputService,
InputRegistry inputRegistry,
ExtractorFactory extractorFactory,
ConverterFactory converterFactory,
StreamService streamService,
StreamRuleService streamRuleService,
IndexSetRegistry indexSetRegistry,
OutputService outputService,
DashboardService dashboardService,
DashboardWidgetCreator dashboardWidgetCreator,
ServerStatus serverStatus,
MessageInputFactory messageInputFactory,
InputLauncher inputLauncher,
GrokPatternService grokPatternService,
DBLookupTableService dbLookupTableService,
DBCacheService dbCacheService,
DBDataAdapterService dbDataAdapterService,
LookupTableService lookupTableService,
TimeRangeFactory timeRangeFactory,
ClusterEventBus clusterBus,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
ScheduledExecutorService scheduler) |
| Constructor and Description |
|---|
OutputBufferProcessor(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
ServerStatus serverStatus,
OutputRouter outputRouter,
MessageOutput defaultMessageOutput) |
| Constructor and Description |
|---|
BundleImporter(InputService inputService,
InputRegistry inputRegistry,
ExtractorFactory extractorFactory,
ConverterFactory converterFactory,
StreamService streamService,
StreamRuleService streamRuleService,
IndexSetRegistry indexSetRegistry,
OutputService outputService,
DashboardService dashboardService,
DashboardWidgetCreator dashboardWidgetCreator,
ServerStatus serverStatus,
MessageInputFactory messageInputFactory,
InputLauncher inputLauncher,
GrokPatternService grokPatternService,
DBLookupTableService dbLookupTableService,
DBCacheService dbCacheService,
DBDataAdapterService dbDataAdapterService,
LookupTableService lookupTableService,
TimeRangeFactory timeRangeFactory,
ClusterEventBus clusterBus,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
ScheduledExecutorService scheduler) |
| Constructor and Description |
|---|
FixDeflectorByDeleteJob(IndexSetRegistry indexSetRegistry,
Indices indices,
ServerStatus serverStatus,
ActivityWriter activityWriter,
Buffers bufferSynchronizer,
NotificationService notificationService) |
FixDeflectorByMoveJob(IndexSetRegistry indexSetRegistry,
Indices indices,
ServerStatus serverStatus,
ActivityWriter activityWriter,
Buffers bufferSynchronizer,
NotificationService notificationService) |
| Constructor and Description |
|---|
InputStateListener(com.google.common.eventbus.EventBus eventBus,
NotificationService notificationService,
ActivityWriter activityWriter,
ServerStatus serverStatus) |
PersistedInputsImpl(InputService inputService,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
GELFAMQPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
AmqpTransport.Factory amqpFactory,
GelfCodec.Factory gelfCodecFactory,
LocalMetricRegistry localRegistry,
GELFAMQPInput.Config config,
GELFAMQPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
GELFHttpInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
HttpTransport.Factory httpTransportFactory,
GelfCodec.Factory gelfCodecFactory,
LocalMetricRegistry localRegistry,
GELFHttpInput.Config config,
GELFHttpInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
GELFKafkaInput(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
KafkaTransport.Factory transport,
GelfCodec.Factory codec,
LocalMetricRegistry localRegistry,
GELFKafkaInput.Config config,
GELFKafkaInput.Descriptor descriptor,
ServerStatus serverStatus) |
GELFKafkaInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
KafkaTransport kafkaTransport,
GelfCodec codec,
LocalMetricRegistry localRegistry,
MessageInput.Config config,
MessageInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
GELFTCPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
TcpTransport.Factory tcpFactory,
GelfCodec.Factory gelfCodecFactory,
LocalMetricRegistry localRegistry,
GELFTCPInput.Config config,
GELFTCPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
GELFUDPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
UdpTransport.Factory udpFactory,
GelfCodec.Factory gelfCodecFactory,
LocalMetricRegistry localRegistry,
GELFUDPInput.Config config,
GELFUDPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
JsonPathInput(Configuration configuration,
HttpPollTransport.Factory transport,
JsonPathCodec.Factory codec,
com.codahale.metrics.MetricRegistry metricRegistry,
LocalMetricRegistry localRegistry,
JsonPathInput.Config config,
JsonPathInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
FakeHttpMessageInput(Configuration configuration,
RandomMessageTransport.Factory transportFactory,
RandomHttpMessageCodec.Factory codecFactory,
com.codahale.metrics.MetricRegistry metricRegistry,
LocalMetricRegistry localRegistry,
FakeHttpMessageInput.Config config,
FakeHttpMessageInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
RawAMQPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
AmqpTransport.Factory amqpFactory,
RawCodec.Factory codecFactory,
LocalMetricRegistry localRegistry,
RawAMQPInput.Config config,
RawAMQPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
RawKafkaInput(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
KafkaTransport.Factory transport,
RawCodec.Factory codec,
LocalMetricRegistry localRegistry,
RawKafkaInput.Config config,
RawKafkaInput.Descriptor descriptor,
ServerStatus serverStatus) |
RawKafkaInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
KafkaTransport kafkaTransport,
RawCodec codec,
LocalMetricRegistry localRegistry,
MessageInput.Config config,
MessageInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
RawTCPInput(Configuration configuration,
TcpTransport.Factory tcpTransportFactory,
RawCodec.Factory rawCodecFactory,
com.codahale.metrics.MetricRegistry metricRegistry,
LocalMetricRegistry localRegistry,
RawTCPInput.Config config,
RawTCPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
RawUDPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
UdpTransport.Factory udpTransportFactory,
RawCodec.Factory rawCodecFactory,
LocalMetricRegistry localRegistry,
RawUDPInput.Config config,
RawUDPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
SyslogAMQPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
AmqpTransport.Factory amqpFactory,
SyslogCodec.Factory codecFactory,
LocalMetricRegistry localRegistry,
SyslogAMQPInput.Config config,
SyslogAMQPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
SyslogKafkaInput(Configuration configuration,
com.codahale.metrics.MetricRegistry metricRegistry,
KafkaTransport.Factory transport,
SyslogCodec.Factory codec,
LocalMetricRegistry localRegistry,
SyslogKafkaInput.Config config,
SyslogKafkaInput.Descriptor descriptor,
ServerStatus serverStatus) |
SyslogKafkaInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
KafkaTransport kafkaTransport,
SyslogCodec codec,
LocalMetricRegistry localRegistry,
MessageInput.Config config,
MessageInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
SyslogTCPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
SyslogTcpTransport.Factory tcpTransportFactory,
SyslogCodec.Factory syslogCodecFactory,
LocalMetricRegistry localRegistry,
SyslogTCPInput.Config config,
SyslogTCPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
SyslogUDPInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
UdpTransport.Factory udpTransportFactory,
SyslogCodec.Factory syslogCodecFactory,
LocalMetricRegistry localRegistry,
SyslogUDPInput.Config config,
SyslogUDPInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
HttpPollTransport(Configuration configuration,
com.google.common.eventbus.EventBus serverEventBus,
ServerStatus serverStatus,
ScheduledExecutorService scheduler,
okhttp3.OkHttpClient httpClient) |
KafkaTransport(Configuration configuration,
LocalMetricRegistry localRegistry,
NodeId nodeId,
com.google.common.eventbus.EventBus serverEventBus,
ServerStatus serverStatus,
ScheduledExecutorService scheduler) |
| Constructor and Description |
|---|
MessageFilterChainProcessor(com.codahale.metrics.MetricRegistry metricRegistry,
Set<MessageFilter> filterRegistry,
Journal journal,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
IndexFailuresPeriodical(IndexFailureService indexFailureService,
Messages messages,
ServerStatus serverStatus,
com.codahale.metrics.MetricRegistry metricRegistry) |
NodePingThread(NodeService nodeService,
NotificationService notificationService,
ActivityWriter activityWriter,
HttpConfiguration httpConfiguration,
ServerStatus serverStatus) |
ThrottleStateUpdaterThread(Journal journal,
ProcessBuffer processBuffer,
NotificationService notificationService,
ServerStatus serverStatus,
com.codahale.metrics.MetricRegistry metricRegistry,
com.github.joschi.jadconfig.util.Size retentionSize) |
VersionCheckThread(NotificationService notificationService,
ServerStatus serverStatus,
VersionCheckConfiguration config,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
okhttp3.OkHttpClient httpClient) |
| Modifier and Type | Method and Description |
|---|---|
ServerStatus |
ServerStatus.addCapabilities(ServerStatus.Capability... capabilities) |
ServerStatus |
ServerStatus.addCapability(ServerStatus.Capability capability) |
| Modifier and Type | Method and Description |
|---|---|
void |
Message.recordCounter(ServerStatus serverStatus,
String name,
int counter) |
void |
Message.recordTiming(ServerStatus serverStatus,
String name,
long elapsedNanos) |
| Constructor and Description |
|---|
MessageInput(com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
Transport transport,
LocalMetricRegistry localRegistry,
Codec codec,
MessageInput.Config config,
MessageInput.Descriptor descriptor,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
SystemProcessingResource(ServerStatus serverStatus) |
SystemShutdownResource(GracefulShutdown gracefulShutdown,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
NodeIdProvider(ServerStatus serverStatus) |
| 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) |
| Constructor and Description |
|---|
PeriodicalsService(Periodicals periodicals,
ServerStatus serverStatus,
Set<Periodical> periodicalSet) |
ServiceManagerListener(ServerStatus serverStatus) |
| Constructor and Description |
|---|
KafkaJournal(File journalDirectory,
ScheduledExecutorService scheduler,
com.github.joschi.jadconfig.util.Size segmentSize,
org.joda.time.Duration segmentAge,
com.github.joschi.jadconfig.util.Size retentionSize,
org.joda.time.Duration retentionAge,
long flushInterval,
org.joda.time.Duration flushAge,
int throttleThresholdPercentage,
com.codahale.metrics.MetricRegistry metricRegistry,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
LoadBalancerStatusResource(ServerStatus serverStatus) |
SystemResource(ServerStatus serverStatus,
ClusterConfigService clusterConfigService) |
| Constructor and Description |
|---|
RestrictToMasterFeature(ServerStatus serverStatus) |
| Constructor and Description |
|---|
StreamRouter(StreamService streamService,
ServerStatus serverStatus,
StreamRouterEngine.Factory routerEngineFactory,
com.google.common.eventbus.EventBus serverEventBus,
ScheduledExecutorService scheduler) |
| Constructor and Description |
|---|
SystemMessageActivityWriter(SystemMessageService systemMessageService,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
GracefulShutdown(ServerStatus serverStatus,
ActivityWriter activityWriter,
Configuration configuration,
BufferSynchronizerService bufferSynchronizerService,
PeriodicalsService periodicalsService,
InputSetupService inputSetupService,
JerseyService jerseyService,
AuditEventSender auditEventSender,
JournalReader journalReader) |
Copyright © 2012–2018 Graylog, Inc.. All rights reserved.