@@ -308,6 +308,7 @@ def dummy_event_stream
308308
309309 assert_equal 0 , @i . write_count
310310 assert_equal 0 , @i . num_errors
311+ assert_equal 0 , @i . instance_variable_get ( :@secondary_chunk_count_metrics ) . get
311312
312313 @i . enqueue_thread_wait
313314 @i . flush_thread_wakeup
@@ -348,6 +349,8 @@ def dummy_event_stream
348349 assert { @i . write_count > prev_write_count }
349350 assert { @i . num_errors == prev_num_errors }
350351
352+ assert { @i . instance_variable_get ( :@secondary_chunk_count_metrics ) . get > 0 }
353+
351354 assert_nil @i . retry
352355
353356 assert_equal [ 'test.tag.1' , event_time ( '2016-04-13 18:33:00' ) . to_i , { "name" => "moris" , "age" => 36 , "message" => "data1" } ] , written [ 0 ]
@@ -388,6 +391,7 @@ def dummy_event_stream
388391
389392 assert_equal 0 , @i . write_count
390393 assert_equal 0 , @i . num_errors
394+ assert_equal 0 , @i . instance_variable_get ( :@secondary_chunk_count_metrics ) . get
391395
392396 @i . enqueue_thread_wait
393397 @i . flush_thread_wakeup
@@ -443,6 +447,8 @@ def dummy_event_stream
443447 assert { @i . buffer . dequeued [ chunks [ 0 ] . unique_id ] . nil? }
444448 assert { chunks . first . empty? }
445449
450+ assert { @i . instance_variable_get ( :@secondary_chunk_count_metrics ) . get > 0 }
451+
446452 assert_nil @i . retry
447453
448454 logs = @i . log . out . logs
@@ -737,6 +743,7 @@ def dummy_event_stream
737743
738744 assert_equal 0 , @i . write_count
739745 assert_equal 0 , @i . num_errors
746+ assert_equal 0 , @i . instance_variable_get ( :@secondary_chunk_count_metrics ) . get
740747
741748 @i . enqueue_thread_wait
742749 @i . flush_thread_wakeup
@@ -765,6 +772,8 @@ def dummy_event_stream
765772 prev_write_count = @i . write_count
766773 end
767774
775+ assert { @i . instance_variable_get ( :@secondary_chunk_count_metrics ) . get > 0 }
776+
768777 # retry_timeout == 60(sec), retry_secondary_threshold == 0.8
769778
770779 assert { now >= first_failure + 60 * 0.8 }
0 commit comments