Rename a parameter

buffer_size_limit ->
buffer_limit_size

Signed-off-by: Kenji Okimoto <[email protected]>

Author: okkez

lib/fluent/plugin/filter_concat.rb

@@ -32,8 +32,8 @@ class ConcatFilter < Filter
     config_param :partial_value, :string, default: nil
     desc "If true, keep partial_key in concatenated records"
     config_param :keep_partial_key, :bool, default: false
-    desc ""
-    config_param :buffer_size_limit, :size, default: 500 * 1024 # 500k
+    desc "The max size of each buffer"
+    config_param :buffer_limit_size, :size, default: 500 * 1024 # 500k
     desc ""
     config_param :buffer_overflow_method, :enum, list: [:ignore, :truncate, :drop, :new], default: :ignore
 
@@ -277,7 +277,7 @@ def continuous_line?(text)
 
     def overflow?(stream_identity, record)
       size = record.keys.sum(&:bytesize) + record.values.sum(&:bytesize)
-      if @buffer_size[stream_identity] + size > @buffer_size_limit
+      if @buffer_size[stream_identity] + size > @buffer_limit_size
         @buffer_size[stream_identity] = 0
         true
       else

test/plugin/test_filter_concat.rb

@@ -741,7 +741,7 @@ def filter_with_time(conf, messages, wait: nil)
         partial_key partial_message
         partial_value true
         keep_partial_key false
-        buffer_size_limit 10
+        buffer_limit_size 10
         buffer_overflow_method ignore
       CONFIG
       messages = [
@@ -768,7 +768,7 @@ def filter_with_time(conf, messages, wait: nil)
         partial_key partial_message
         partial_value true
         keep_partial_key false
-        buffer_size_limit 60
+        buffer_limit_size 60
         buffer_overflow_method truncate
       CONFIG
       messages = [
@@ -797,7 +797,7 @@ def filter_with_time(conf, messages, wait: nil)
         partial_key partial_message
         partial_value true
         keep_partial_key false
-        buffer_size_limit 100
+        buffer_limit_size 100
         buffer_overflow_method drop
       CONFIG
       messages = [
@@ -824,7 +824,7 @@ def filter_with_time(conf, messages, wait: nil)
         partial_key partial_message
         partial_value true
         keep_partial_key false
-        buffer_size_limit 90
+        buffer_limit_size 90
         buffer_overflow_method new
       CONFIG
       messages = [