@@ -40,15 +40,15 @@ def add_datapoints(self, stats):
40
40
self .add_gauge_value ('FSM/Object Size/100th Percentile' , 'bytes' ,
41
41
stats .get ('node_get_fsm_objsize_100' , 0 ))
42
42
43
- self .add_gauge_value ('FSM/Siblings/Mean' , '' ,
43
+ self .add_gauge_value ('FSM/Siblings/Mean' , 'siblings ' ,
44
44
stats .get ('node_get_fsm_siblings_mean' , 0 ))
45
- self .add_gauge_value ('FSM/Siblings/Mean' , '' ,
45
+ self .add_gauge_value ('FSM/Siblings/Mean' , 'siblings ' ,
46
46
stats .get ('node_get_fsm_siblings_media' , 0 ))
47
- self .add_gauge_value ('FSM/Siblings/90th Percentile' , '' ,
47
+ self .add_gauge_value ('FSM/Siblings/90th Percentile' , 'siblings ' ,
48
48
stats .get ('node_get_fsm_siblings_90' , 0 ))
49
- self .add_gauge_value ('FSM/Siblings/95th Percentile' , '' ,
49
+ self .add_gauge_value ('FSM/Siblings/95th Percentile' , 'siblings ' ,
50
50
stats .get ('node_get_fsm_siblings_95' , 0 ))
51
- self .add_gauge_value ('FSM/Siblings/100th Percentile' , '' ,
51
+ self .add_gauge_value ('FSM/Siblings/100th Percentile' , 'siblings ' ,
52
52
stats .get ('node_get_fsm_siblings_100' , 0 ))
53
53
54
54
self .add_gauge_value ('FSM/Time/Get/Mean' , 'us' ,
@@ -73,20 +73,20 @@ def add_datapoints(self, stats):
73
73
self .add_gauge_value ('FSM/Time/Put/100th Percentile' , 'us' ,
74
74
stats .get ('node_put_fsm_time_100' , 0 ))
75
75
76
- self .add_derive_value ('Failures/Pre-commit' , '' ,
76
+ self .add_derive_value ('Failures/Pre-commit' , 'failures ' ,
77
77
stats .get ('precommit_fail' , 0 ))
78
- self .add_derive_value ('Failures/Post-commit' , '' ,
78
+ self .add_derive_value ('Failures/Post-commit' , 'failures ' ,
79
79
stats .get ('postcommit_fail' , 0 ))
80
80
81
- self .add_derive_value ('Gossip/Ignored' , '' ,
81
+ self .add_derive_value ('Gossip/Ignored' , 'gossip ' ,
82
82
stats .get ('ignored_gossip_total' , 0 ))
83
- self .add_derive_value ('Gossip/Received' , '' ,
83
+ self .add_derive_value ('Gossip/Received' , 'gossip ' ,
84
84
stats .get ('gossip_received' , 0 ))
85
85
86
86
self .add_derive_value ('Handoff Timeouts' , '' ,
87
87
stats .get ('handoff_timeouts' , 0 ))
88
88
89
- self .add_gauge_value ('Mappers/Executing' , '' ,
89
+ self .add_gauge_value ('Mappers/Executing' , 'timeouts ' ,
90
90
stats .get ('executing_mappers' , 0 ))
91
91
92
92
self .add_gauge_value ('Memory/Allocated' , 'bytes' ,
@@ -112,60 +112,60 @@ def add_datapoints(self, stats):
112
112
self .add_gauge_value ('Memory/Erlang/Total' , 'bytes' ,
113
113
stats .get ('memory_total' , 0 ))
114
114
115
- self .add_gauge_value ('Nodes/Connected' , '' ,
115
+ self .add_gauge_value ('Nodes/Connected' , 'nodes ' ,
116
116
len (stats .get ('connected_nodes' , list ())))
117
117
118
- self .add_gauge_value ('Pipeline/Active' , '' ,
118
+ self .add_gauge_value ('Pipeline/Active' , 'pipelines ' ,
119
119
stats .get ('pipeline_active' , 0 ))
120
- self .add_derive_value ('Pipeline/Created' , '' ,
120
+ self .add_derive_value ('Pipeline/Created' , 'pipelines ' ,
121
121
stats .get ('pipeline_create_count' , 0 ))
122
- self .add_derive_value ('Pipeline/Creation Errors' , '' ,
122
+ self .add_derive_value ('Pipeline/Creation Errors' , 'pipelines ' ,
123
123
stats .get ('pipeline_create_error_count' , 0 ))
124
124
125
- self .add_gauge_value ('Processes/OS' , '' ,
125
+ self .add_gauge_value ('Processes/OS' , 'processes ' ,
126
126
stats .get ('cpu_nprocs' , 0 ))
127
127
128
- self .add_gauge_value ('Processes/Erlang' , '' ,
128
+ self .add_gauge_value ('Processes/Erlang' , 'processes ' ,
129
129
stats .get ('cpu_nprocs' , 0 ))
130
130
131
131
self .add_gauge_value ('Protocol Buffer Connections' , 'active' ,
132
132
stats .get ('pbc_active' , 0 ))
133
133
self .add_derive_value ('Protocol Buffer Connections' , 'total' ,
134
134
stats .get ('pbc_connects_total' , 0 ))
135
135
136
- self .add_derive_value ('Read Repairs' , '' ,
136
+ self .add_derive_value ('Read Repairs' , 'reads ' ,
137
137
stats .get ('read_repairs_total' , 0 ))
138
138
139
- self .add_derive_value ('Requests/Gets' , '' ,
139
+ self .add_derive_value ('Requests/Gets' , 'requests ' ,
140
140
stats .get ('node_gets_total' , 0 ))
141
- self .add_derive_value ('Requests/Puts' , '' ,
141
+ self .add_derive_value ('Requests/Puts' , 'requests ' ,
142
142
stats .get ('node_puts_total' , 0 ))
143
- self .add_derive_value ('Requests/Redirected' , '' ,
143
+ self .add_derive_value ('Requests/Redirected' , 'requests ' ,
144
144
stats .get ('coord_redirs_total' , 0 ))
145
145
146
146
147
- self .add_gauge_value ('Ring/Members' , '' ,
147
+ self .add_gauge_value ('Ring/Members' , 'members ' ,
148
148
len (stats .get ('ring_members' , list ())))
149
- self .add_gauge_value ('Ring/Partitions' , '' ,
149
+ self .add_gauge_value ('Ring/Partitions' , 'partitions ' ,
150
150
stats .get ('ring_num_partitions' , 0 ))
151
- self .add_gauge_value ('Ring/Size' , '' ,
151
+ self .add_gauge_value ('Ring/Size' , 'members ' ,
152
152
stats .get ('ring_creation_size' , 0 ))
153
- self .add_derive_value ('Ring/Reconciled' , '' ,
153
+ self .add_derive_value ('Ring/Reconciled' , 'members ' ,
154
154
stats .get ('rings_reconciled_total' , 0 ))
155
155
156
- self .add_derive_value ('VNodes/Gets' , '' ,
156
+ self .add_derive_value ('VNodes/Gets' , 'vnodes ' ,
157
157
stats .get ('vnode_gets_total' , 0 ))
158
- self .add_derive_value ('VNodes/Puts' , '' ,
158
+ self .add_derive_value ('VNodes/Puts' , 'vnodes ' ,
159
159
stats .get ('vnode_puts_total' , 0 ))
160
160
161
- self .add_derive_value ('VNodes/Index' , '' ,
161
+ self .add_derive_value ('VNodes/Index' , 'deletes ' ,
162
162
stats .get ('vnode_index_deletes_total' , 0 ))
163
- self .add_derive_value ('VNodes/Index' , '' ,
163
+ self .add_derive_value ('VNodes/Index' , 'delete-postings ' ,
164
164
stats .get ('vnode_index_deletes_postings_total' ,
165
165
0 ))
166
- self .add_derive_value ('VNodes/Index' , '' ,
166
+ self .add_derive_value ('VNodes/Index' , 'reads ' ,
167
167
stats .get ('vnode_index_reads_total' , 0 ))
168
- self .add_derive_value ('VNodes/Index' , '' ,
168
+ self .add_derive_value ('VNodes/Index' , 'writes ' ,
169
169
stats .get ('vnode_index_writes_total' , 0 ))
170
- self .add_derive_value ('VNodes/Index' , '' ,
170
+ self .add_derive_value ('VNodes/Index' , 'postings ' ,
171
171
stats .get ('vnode_writes_postings_total' , 0 ))
0 commit comments