diff --git a/plugins/inputs/riak/riak.go b/plugins/inputs/riak/riak.go index 56231176b..19bf7df04 100644 --- a/plugins/inputs/riak/riak.go +++ b/plugins/inputs/riak/riak.go @@ -75,6 +75,8 @@ type riakStats struct { VnodeIndexWritesTotal int64 `json:"vnode_index_writes_total"` VnodePuts int64 `json:"vnode_puts"` VnodePutsTotal int64 `json:"vnode_puts_total"` + ReadRepairs int64 `json:"read_repairs"` + ReadRepairsTotal int64 `json:"read_repairs_total"` } // A sample configuration to only gather stats from localhost, default port. @@ -187,6 +189,8 @@ func (r *Riak) gatherServer(s string, acc telegraf.Accumulator) error { "vnode_index_writes_total": stats.VnodeIndexWritesTotal, "vnode_puts": stats.VnodePuts, "vnode_puts_total": stats.VnodePutsTotal, + "read_repairs": stats.ReadRepairs, + "read_repairs_total": stats.ReadRepairsTotal, } // Accumulate the tags and values diff --git a/plugins/inputs/riak/riak_test.go b/plugins/inputs/riak/riak_test.go index 49da4e7ea..09f9a961f 100644 --- a/plugins/inputs/riak/riak_test.go +++ b/plugins/inputs/riak/riak_test.go @@ -66,6 +66,8 @@ func TestRiak(t *testing.T) { "node_put_fsm_time_99": int64(84422), "node_put_fsm_time_mean": int64(10832), "node_put_fsm_time_median": int64(4085), + "read_repairs": int64(2), + "read_repairs_total": int64(7918375), "node_puts": int64(1155), "node_puts_total": int64(444895769), "pbc_active": int64(360),