| Constructor and Description |
|---|
DefaultJobSchedulerConfig(LeaderElectionService leaderElectionService) |
| Modifier and Type | Class and Description |
|---|---|
class |
AutomaticLeaderElectionService |
class |
FakeLeaderElectionService
Leader election when we don't care (i.e.
|
class |
StaticLeaderElectionService
Leader election based on the static
Configuration.isLeader() setting in the configuration file. |
| Constructor and Description |
|---|
InputEventListener(com.google.common.eventbus.EventBus eventBus,
InputLauncher inputLauncher,
InputRegistry inputRegistry,
InputService inputService,
NodeId nodeId,
LeaderElectionService leaderElectionService,
PersistedInputs persistedInputs,
ServerStatus serverStatus) |
| Constructor and Description |
|---|
NodePingThread(NodeService nodeService,
NotificationService notificationService,
ActivityWriter activityWriter,
HttpConfiguration httpConfiguration,
ServerStatus serverStatus,
LeaderElectionService leaderElectionService) |
| Constructor and Description |
|---|
PeriodicalsService(Periodicals periodicals,
Set<Periodical> allPeriodicals,
com.google.common.eventbus.EventBus eventBus,
LeaderElectionService leaderElectionService) |
| Constructor and Description |
|---|
InputLauncher(IOState.Factory<MessageInput> inputStateFactory,
InputBuffer inputBuffer,
PersistedInputs persistedInputs,
InputRegistry inputRegistry,
com.codahale.metrics.MetricRegistry metricRegistry,
Configuration configuration,
LeaderElectionService leaderElectionService) |
| Constructor and Description |
|---|
RestrictToLeaderFilter(LeaderElectionService leaderElectionService) |
Copyright © 2012–2022 Graylog, Inc.. All rights reserved.