From fe16ee700e532d82a00b8926ad11923355450ddd Mon Sep 17 00:00:00 2001 From: Boaz Leskes Date: Tue, 4 Mar 2014 16:58:43 +0100 Subject: [PATCH] Made `marvel.agent.shard_stats.enabled` dynamically updatable Relates to #20 --- .../java/org/elasticsearch/marvel/agent/AgentService.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/agent/src/main/java/org/elasticsearch/marvel/agent/AgentService.java b/agent/src/main/java/org/elasticsearch/marvel/agent/AgentService.java index accb996182f547..608972e311c089 100644 --- a/agent/src/main/java/org/elasticsearch/marvel/agent/AgentService.java +++ b/agent/src/main/java/org/elasticsearch/marvel/agent/AgentService.java @@ -124,6 +124,7 @@ public AgentService(Settings settings, IndicesService indicesService, nodeSettingsService.addListener(this); dynamicSettings.addDynamicSetting(SETTINGS_INTERVAL); dynamicSettings.addDynamicSetting(SETTINGS_INDICES + ".*"); // array settings + dynamicSettings.addDynamicSetting(SETTINGS_SHARD_STATS_ENABLED); } protected void applyIntervalSettings() { @@ -202,6 +203,12 @@ public void onRefreshSettings(Settings settings) { logger.info("sampling indices updated to [{}]", Strings.arrayToCommaDelimitedString(indices)); indicesToExport = indices; } + + Boolean shardsExport = settings.getAsBoolean(SETTINGS_SHARD_STATS_ENABLED, null); + if (shardsExport != null) { + logger.info("updating " + SETTINGS_SHARD_STATS_ENABLED + " to [" + shardsExport + "]"); + exportShardStats = shardsExport; + } } class ExportingWorker implements Runnable {