From be14c9fcb5f41979116eb8b2ce71f413311f5ed2 Mon Sep 17 00:00:00 2001 From: Jeff Cantrill Date: Fri, 22 Jan 2021 21:14:14 -0500 Subject: [PATCH] fix #263: use filter in lieu of filter_stream as recommended optimization --- test/plugin/test_filter_kubernetes_metadata.rb | 13 ++----------- 1 file changed, 2 insertions(+), 11 deletions(-) diff --git a/test/plugin/test_filter_kubernetes_metadata.rb b/test/plugin/test_filter_kubernetes_metadata.rb index 3067353..7bf93aa 100644 --- a/test/plugin/test_filter_kubernetes_metadata.rb +++ b/test/plugin/test_filter_kubernetes_metadata.rb @@ -145,18 +145,9 @@ def emit_with_tag(tag, msg = {}, config = ' ') d = create_driver(config) d.run(default_tag: tag) do - d.feed(@time, msg) + d.feed(msg) end - d.filtered.map(&:last) - end - - test 'nil event stream' do - # not certain how this is possible but adding test to properly - # guard against this condition we have seen - test for nil, - # empty, no empty method, not an event stream - plugin = create_driver.instance - plugin.filter_stream('tag', nil) - plugin.filter_stream('tag', Fluent::MultiEventStream.new) + d.filtered_records end test 'inability to connect to the api server handles exception and doensnt block pipeline' do