buffer.rb in fluentd-0.12.21

- old
+ new

@@ -11,10 +11,16 @@
 #    distributed under the License is distributed on an "AS IS" BASIS,
 #    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 #    See the License for the specific language governing permissions and
 #    limitations under the License.
 #
+
+require 'monitor'
+require 'fileutils'
+
+require 'fluent/configurable'
+
 module Fluent
   class BufferError < StandardError
   end
 
   class BufferChunkLimitError < BufferError
@@ -138,14 +144,14 @@
 
     # This configuration assumes plugins to send records to a remote server.
     # Local file based plugins which should provide more reliability and efficiency
     # should override buffer_chunk_limit with a larger size.
     desc 'The size of each buffer chunk.'
-    config_param :buffer_chunk_limit, :size, :default => 8*1024*1024
+    config_param :buffer_chunk_limit, :size, default: 8*1024*1024
     desc 'The length limit of the chunk queue.'
-    config_param :buffer_queue_limit, :integer, :default => 256
+    config_param :buffer_queue_limit, :integer, default: 256
     desc 'The action when the size of buffer queue exceeds the buffer_queue_limit.'
-    config_param :buffer_queue_full_action, :enum, :list => [:exception, :block], :default => :exception
+    config_param :buffer_queue_full_action, :enum, list: [:exception, :block], default: :exception
 
     alias chunk_limit buffer_chunk_limit
     alias chunk_limit= buffer_chunk_limit=
     alias queue_limit buffer_queue_limit
     alias queue_limit= buffer_queue_limit=