File tree Expand file tree Collapse file tree 2 files changed +17
-2
lines changed
Expand file tree Collapse file tree 2 files changed +17
-2
lines changed Original file line number Diff line number Diff line change @@ -1395,4 +1395,15 @@ def plugin_id_for_test?
13951395 end
13961396 end
13971397 end
1398+
1399+ test 'can use metrics plugins and fallback methods' do
1400+ @d = create_driver
1401+
1402+ %w[ healthy_nodes_count_metrics registered_nodes_count_metrics ] . each do |metric_name |
1403+ assert_true @d . instance . instance_variable_get ( :"@#{ metric_name } " ) . is_a? ( Fluent ::Plugin ::Metrics )
1404+ end
1405+
1406+ assert_equal 0 , @d . instance . healthy_nodes_count
1407+ assert_equal 0 , @d . instance . registered_nodes_count
1408+ end
13981409end
Original file line number Diff line number Diff line change @@ -226,17 +226,21 @@ def waiting(seconds)
226226 test 'can use metrics plugins and fallback methods' do
227227 @i . configure ( config_element ( ) )
228228
229- %w[ num_errors_metrics emit_count_metrics emit_size_metrics emit_records_metrics
230- write_count_metrics rollback_count_metrics flush_time_count_metrics slow_flush_count_metrics ] . each do |metric_name |
229+ %w[ num_errors_metrics emit_count_metrics emit_size_metrics emit_records_metrics write_count_metrics
230+ write_secondary_count_metrics rollback_count_metrics flush_time_count_metrics slow_flush_count_metrics ] . each do |metric_name |
231231 assert_true @i . instance_variable_get ( :"@#{ metric_name } " ) . is_a? ( Fluent ::Plugin ::Metrics )
232232 end
233233
234234 assert_equal 0 , @i . num_errors
235235 assert_equal 0 , @i . emit_count
236+ assert_equal 0 , @i . emit_records
236237 assert_equal 0 , @i . emit_size
237238 assert_equal 0 , @i . emit_records
238239 assert_equal 0 , @i . write_count
240+ assert_equal 0 , @i . write_secondary_count
239241 assert_equal 0 , @i . rollback_count
242+ assert_equal 0 , @i . flush_time_count
243+ assert_equal 0 , @i . slow_flush_count
240244 end
241245
242246 data ( :new_api => :chunk ,
You can’t perform that action at this time.
0 commit comments