dom/telegraf
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

cassandra plugin lower version support added

Browse Source 
closes #1427
closes #1508
This commit is contained in:
ashish
2016-07-18 12:06:41 +05:30
committed by Cameron Sparr
parent 704d9ad76c
commit 6afe9ceef1
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
plugins/inputs/cassandra/cassandra.go
View File

@@ -148,7 +148,7 @@ func (c cassandraMetric) addTagsFields(out map[string]interface{}) {
tokens := parseJmxMetricRequest(r.(map[string]interface{})["mbean"].(string))
// Requests with wildcards for keyspace or table names will return nested
// maps in the json response
if tokens["type"] == "Table" && (tokens["keyspace"] == "*" ||
if (tokens["type"] == "Table" || tokens["type"] == "ColumnFamily") && (tokens["keyspace"] == "*" ||
tokens["scope"] == "*") {
if valuesMap, ok := out["value"]; ok {
for k, v := range valuesMap.(map[string]interface{}) {