maxmustermann/kibana
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Setting human_readable to false while exporting node stats.

Browse source
This commit is contained in:
Boaz Leskes 2013-05-22 13:47:24 +02:00
parent 1e786c7c94
commit 8bce30d892
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/main/java/com/elasticsearch/dash/exporters/ESExporter.java
View file

@ -20,6 +20,7 @@ package com.elasticsearch.dash.exporters;
import com.elasticsearch.dash.Exporter; import com.elasticsearch.dash.Exporter;
import com.google.common.collect.ImmutableMap;
import org.elasticsearch.ElasticSearchException; import org.elasticsearch.ElasticSearchException;
import org.elasticsearch.ElasticSearchIllegalArgumentException; import org.elasticsearch.ElasticSearchIllegalArgumentException;
import org.elasticsearch.action.admin.cluster.node.stats.NodeStats; import org.elasticsearch.action.admin.cluster.node.stats.NodeStats;
@ -40,7 +41,7 @@ import java.net.HttpURLConnection;
import java.net.MalformedURLException; import java.net.MalformedURLException;
import java.net.URL; import java.net.URL;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.util.Date; import java.util.*;
public class ESExporter extends AbstractLifecycleComponent<ESExporter> implements Exporter<ESExporter> { public class ESExporter extends AbstractLifecycleComponent<ESExporter> implements Exporter<ESExporter> {
@ -52,6 +53,9 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
final ESLogger logger = ESLoggerFactory.getLogger(ESExporter.class.getName()); final ESLogger logger = ESLoggerFactory.getLogger(ESExporter.class.getName());
final ToXContent.Params xContentParams;
public ESExporter(Settings settings, ClusterName clusterName) { public ESExporter(Settings settings, ClusterName clusterName) {
super(settings); super(settings);
@ -72,6 +76,9 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
} }
xContentParams = new ToXContent.MapParams(ImmutableMap.of("human_readable","false"));
logger.info("ESExporter initialized. Target: {}:{} Index prefix set to {}", targetHost, targetPort, targetIndexPrefix ); logger.info("ESExporter initialized. Target: {}:{} Index prefix set to {}", targetHost, targetPort, targetIndexPrefix );
// explode early on broken settings // explode early on broken settings
getTargetURL("test"); getTargetURL("test");
@ -92,6 +99,7 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
return "ESExporter"; return "ESExporter";
} }
@Override @Override
public void exportNodeStats(NodeStats nodeStats) { public void exportNodeStats(NodeStats nodeStats) {
URL url = getTargetURL("nodestats"); URL url = getTargetURL("nodestats");
@ -106,7 +114,7 @@ public class ESExporter extends AbstractLifecycleComponent<ESExporter> implement
XContentBuilder builder = XContentFactory.smileBuilder(os); XContentBuilder builder = XContentFactory.smileBuilder(os);
builder.startObject(); builder.startObject();
nodeStats.toXContent(builder, ToXContent.EMPTY_PARAMS); nodeStats.toXContent(builder, xContentParams);
builder.endObject(); builder.endObject();
builder.close(); builder.close();