本文整理汇总了Java中org.graylog2.plugin.cluster.ClusterConfigService类的典型用法代码示例。如果您正苦于以下问题：Java ClusterConfigService类的具体用法？Java ClusterConfigService怎么用？Java ClusterConfigService使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ClusterConfigService类属于org.graylog2.plugin.cluster包，在下文中一共展示了ClusterConfigService类的18个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: SerializedLogEventCodec
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public SerializedLogEventCodec(@Assisted Configuration configuration,
NodeId nodeId,
NodeService nodeService,
ClusterConfigService clusterConfigService) {
super(configuration);
this.includeSource = configuration.getBoolean(CK_INCLUDE_SOURCE, true);
this.includeThreadContext = configuration.getBoolean(CK_INCLUDE_THREAD_CONTEXT, true);
this.includeStackTrace = configuration.getBoolean(CK_INCLUDE_STACK_TRACE, true);
this.includeExceptionCause = configuration.getBoolean(CK_INCLUDE_EXCEPTION_CAUSE, true);
final ClusterId clusterIdBean = clusterConfigService.get(ClusterId.class);
this.clusterId = clusterIdBean == null ? null : clusterIdBean.clusterId();
this.nodeId = nodeId.toString();
String nodeHostname;
try {
final Node node = nodeService.byNodeId(nodeId);
nodeHostname = node.getHostname();
} catch (NodeNotFoundException e) {
nodeHostname = null;
}
this.hostname = nodeHostname;
}
开发者ID:graylog-labs，项目名称:graylog-plugin-internal-logs，代码行数:25，代码来源:SerializedLogEventCodec.java
示例2: AggregatesMaintenance
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public AggregatesMaintenance(AlertService alertService, RuleService ruleService, StreamService streamService, HistoryItemService historyItemService, ReportScheduleService reportScheduleService, @Named("daemonScheduler") ScheduledExecutorService scheduler, ClusterConfigService clusterConfigService, EventBus eventBus) {
this.alertService = alertService;
this.ruleService = ruleService;
this.streamService = streamService;
this.historyItemService = historyItemService;
this.reportScheduleService = reportScheduleService;
this.clusterConfigService = clusterConfigService;
this.scheduler = scheduler;
final AggregatesConfig config = clusterConfigService.getOrDefault(AggregatesConfig.class,
AggregatesConfig.defaultConfig());
this.config = new AtomicReference<>(config);
eventBus.register(this);
}
开发者ID:cvtienhoven，项目名称:graylog-plugin-aggregates，代码行数:18，代码来源:AggregatesMaintenance.java
示例3: AggregatesAlertCondition
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@AssistedInject
public AggregatesAlertCondition(Searches searches,
ClusterConfigService clusterConfigService,
HistoryItemService historyItemService,
@Assisted Stream stream,
@Nullable @Assisted("id") String id,
@Assisted DateTime createdAt,
@Assisted("userid") String creatorUserId,
@Assisted Map<String, Object> parameters,
@Assisted("title") @Nullable String title) {
super(stream, id, AggregatesUtil.ALERT_CONDITION_TYPE, createdAt, creatorUserId, parameters, title);
this.description = (String) parameters.get("description");
this.query = (String) parameters.get("query");
this.field = (String) parameters.get("field");
this.numberOfMatches = (Long)parameters.get("number_of_matches");
this.matchMoreOrEqual = parameters.get("match_more_or_equal") == null ? true : (boolean) parameters.get("match_more_or_equal");
this.searches = searches;
this.limit = 100;
this.interval = Tools.getNumber(parameters.get("interval"), Integer.valueOf(1)).intValue();
this.ruleName = (String) parameters.get("rule_name");
this.clusterConfigService = clusterConfigService;
this.historyItemService= historyItemService;
}
开发者ID:cvtienhoven，项目名称:graylog-plugin-aggregates，代码行数:26，代码来源:AggregatesAlertCondition.java
示例4: UsageStatsNodePeriodical
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public UsageStatsNodePeriodical(UsageStatsNodeService usageStatsNodeService,
NodeId nodeId,
ServerStatus serverStatus,
UsageStatsConfiguration config,
ClusterConfigService clusterConfigService,
@CompressingHttpClient OkHttpClient httpClient,
@SmileObjectMapper ObjectMapper objectMapper) {
this(
usageStatsNodeService,
nodeId,
serverStatus,
config,
clusterConfigService,
EvictingQueue.<UsageStatsRequest>create(config.getMaxQueueSize()),
httpClient,
objectMapper);
}
开发者ID:Graylog2，项目名称:graylog-plugin-anonymous-usage-statistics，代码行数:19，代码来源:UsageStatsNodePeriodical.java
示例5: ClusterCollector
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public ClusterCollector(ClusterStatsService clusterStatsService,
ElasticsearchCollector elasticsearchCollector,
MongoCollector mongoCollector,
CollectorCollector collectorCollector,
Counts counts,
@Named("usage_statistics_report_interval") Duration reportInterval,
ClusterConfigService clusterConfigService) {
this.clusterStatsService = checkNotNull(clusterStatsService);
this.elasticsearchCollector = checkNotNull(elasticsearchCollector);
this.mongoCollector = checkNotNull(mongoCollector);
this.collectorCollector = checkNotNull(collectorCollector);
this.counts = checkNotNull(counts);
this.reportIntervalMs = checkNotNull(reportInterval).toMilliseconds();
this.clusterConfigService = checkNotNull(clusterConfigService);
}
开发者ID:Graylog2，项目名称:graylog-plugin-anonymous-usage-statistics，代码行数:17，代码来源:ClusterCollector.java
示例6: NodeCollector
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public NodeCollector(NodeId nodeId,
ServerStatus serverStatus,
MetricRegistry metricRegistry,
StatsService statsService,
InputService inputService,
ClusterConfigService clusterConfigService,
Set<PluginMetaData> plugins,
@Named("usage_statistics_report_interval") Duration reportInterval,
@Named("installation_source") String installationSource) {
this.nodeId = checkNotNull(nodeId);
this.serverStatus = checkNotNull(serverStatus);
this.metricRegistry = checkNotNull(metricRegistry);
this.statsService = checkNotNull(statsService);
this.inputService = checkNotNull(inputService);
this.clusterConfigService = checkNotNull(clusterConfigService);
this.plugins = checkNotNull(plugins);
this.reportIntervalMs = checkNotNull(reportInterval).toMilliseconds();
this.installationSource = checkNotNull(installationSource);
}
开发者ID:Graylog2，项目名称:graylog-plugin-anonymous-usage-statistics，代码行数:21，代码来源:NodeCollector.java
示例7: UsageStatsClusterPeriodical
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public UsageStatsClusterPeriodical(UsageStatsClusterService usageStatsClusterService,
ServerStatus serverStatus,
UsageStatsConfiguration config,
ClusterConfigService clusterConfigService,
@CompressingHttpClient OkHttpClient httpClient,
@SmileObjectMapper ObjectMapper objectMapper) {
this(
usageStatsClusterService,
serverStatus,
config,
clusterConfigService,
EvictingQueue.<UsageStatsRequest>create(config.getMaxQueueSize()),
httpClient,
objectMapper);
}
开发者ID:Graylog2，项目名称:graylog-plugin-anonymous-usage-statistics，代码行数:17，代码来源:UsageStatsClusterPeriodical.java
示例8: GeoIpProcessor
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public GeoIpProcessor(ClusterConfigService clusterConfigService,
@Named("daemonScheduler") ScheduledExecutorService scheduler,
EventBus eventBus,
MetricRegistry metricRegistry) {
this.clusterConfigService = clusterConfigService;
this.scheduler = scheduler;
this.metricRegistry = metricRegistry;
final GeoIpResolverConfig config = clusterConfigService.getOrDefault(GeoIpResolverConfig.class,
GeoIpResolverConfig.defaultConfig());
this.config = new AtomicReference<>(config);
this.filterEngine = new AtomicReference<>(new GeoIpResolverEngine(config, metricRegistry));
eventBus.register(this);
}
开发者ID:Graylog2，项目名称:graylog-plugin-map-widget，代码行数:17，代码来源:GeoIpProcessor.java
示例9: CloudTrailTransport
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public CloudTrailTransport(@Assisted final Configuration configuration,
final ClusterConfigService clusterConfigService,
final EventBus serverEventBus,
final ServerStatus serverStatus,
@AWSObjectMapper ObjectMapper objectMapper,
@Named("http_proxy_uri") @Nullable URI httpProxyUri,
LocalMetricRegistry localRegistry) {
super(serverEventBus, configuration);
this.clusterConfigService = clusterConfigService;
this.serverStatus = serverStatus;
this.objectMapper = objectMapper;
this.httpProxyUri = httpProxyUri;
this.localRegistry = localRegistry;
}
开发者ID:Graylog2，项目名称:graylog-plugin-aws，代码行数:17，代码来源:CloudTrailTransport.java
示例10: setUp
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Before
public void setUp()
{
backupConfigurationMock = mock(BackupConfiguration.class);
clusterConfigServiceMock = mock(ClusterConfigService.class);
}
开发者ID:fbalicchia，项目名称:graylog-plugin-backup-configuration，代码行数:8，代码来源:BackConfigurationPeriodicalTest.java
示例11: UsageStatsPeriodical
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
protected UsageStatsPeriodical(UsageStatsConfiguration config,
ClusterConfigService clusterConfigService,
EvictingQueue<UsageStatsRequest> usageStatsRequestsQueue,
OkHttpClient httpClient,
ObjectMapper objectMapper,
String filenamePattern) {
this.config = checkNotNull(config);
this.clusterConfigService = checkNotNull(clusterConfigService);
this.cachedRequestsQueue = checkNotNull(usageStatsRequestsQueue);
this.httpClient = checkNotNull(httpClient);
this.objectMapper = checkNotNull(objectMapper);
this.filenamePattern = checkNotNull(filenamePattern);
}
开发者ID:Graylog2，项目名称:graylog-plugin-anonymous-usage-statistics，代码行数:14，代码来源:UsageStatsPeriodical.java
示例12: UsageStatsOptOutService
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public UsageStatsOptOutService(ClusterConfigService clusterConfigService,
UsageStatsConfiguration config,
OkHttpClient httpClient,
@SmileObjectMapper ObjectMapper objectMapper) {
this.clusterConfigService = clusterConfigService;
this.config = config;
this.httpClient = httpClient;
this.objectMapper = objectMapper;
}
开发者ID:Graylog2，项目名称:graylog-plugin-anonymous-usage-statistics，代码行数:11，代码来源:UsageStatsOptOutService.java
示例13: KinesisTransport
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public KinesisTransport(@Assisted final Configuration configuration,
org.graylog2.Configuration graylogConfiguration,
final ClusterConfigService clusterConfigService,
final NodeId nodeId,
LocalMetricRegistry localRegistry) {
this.clusterConfigService = clusterConfigService;
this.configuration = configuration;
this.graylogConfiguration = graylogConfiguration;
this.nodeId = nodeId;
this.localRegistry = localRegistry;
}
开发者ID:Graylog2，项目名称:graylog-plugin-aws，代码行数:13，代码来源:KinesisTransport.java
示例14: BackupConfigurationPeriodical
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public BackupConfigurationPeriodical(BackupService backupService, ClusterConfigService clusterConfigService)
{
this.backupService = backupService;
this.clusterConfigService = clusterConfigService;
}
开发者ID:fbalicchia，项目名称:graylog-plugin-backup-configuration，代码行数:7，代码来源:BackupConfigurationPeriodical.java
示例15: BackupResource
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public BackupResource(BackupService backupService, ClusterConfigService clusterConfigService)
{
this.backupService = backupService;
this.clusterConfigService = clusterConfigService;
}
开发者ID:fbalicchia，项目名称:graylog-plugin-backup-configuration，代码行数:7，代码来源:BackupResource.java
示例16: LegacyDefaultStreamMigration
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public LegacyDefaultStreamMigration(ClusterConfigService clusterConfigService, PipelineStreamConnectionsService connectionsService) {
this.clusterConfigService = clusterConfigService;
this.connectionsService = connectionsService;
}
开发者ID:Graylog2，项目名称:graylog-plugin-pipeline-processor，代码行数:6，代码来源:LegacyDefaultStreamMigration.java
示例17: CollectorSystemConfigurationSupplier
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public CollectorSystemConfigurationSupplier(ClusterConfigService clusterConfigService) {
this.clusterConfigService = clusterConfigService;
this.config = null;
}
开发者ID:Graylog2，项目名称:graylog-plugin-collector，代码行数:6，代码来源:CollectorSystemConfigurationSupplier.java
示例18: MapDataResource
import org.graylog2.plugin.cluster.ClusterConfigService; //导入依赖的package包/类
@Inject
public MapDataResource(MapDataSearch search, Searches searches, ClusterConfigService clusterConfigService, DecoratorProcessor decoratorProcessor) {
super(searches, clusterConfigService, decoratorProcessor);
this.search = search;
}
开发者ID:Graylog2，项目名称:graylog-plugin-map-widget，代码行数:6，代码来源:MapDataResource.java
注：本文中的org.graylog2.plugin.cluster.ClusterConfigService类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论