Method configure has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def configure(conf)
      super

      # initialize <match> and <filter> elements
      conf.elements('filter', 'match').each { |e|

• Read up
  Read up

Method start has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

    def start
      @thread = Thread.new do
        $log.disable_events(Thread.current)

        loop do

• Read up
  Read up

Method config_parameter_option_validate! has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

      def config_parameter_option_validate!(name, type, **kwargs, &block)
        if type.nil? && !block
          type = :string
        end
        kwargs.each_key do |key|

• Read up
  Read up

Method cert_option_server_validate! has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

      def cert_option_server_validate!(conf)
        case
        when conf.cert_path
          raise Fluent::ConfigError, "private_key_path is required when cert_path is specified" unless conf.private_key_path
          log.warn "For security reason, setting private_key_passphrase is recommended when cert_path is specified" unless conf.private_key_passphrase

• Read up
  Read up

Method parameter_configuration has a Cognitive Complexity of 13 (exceeds 5 allowed). Consider refactoring.

Open

      def parameter_configuration(name, type = nil, **kwargs, &block)
        config_parameter_option_validate!(name, type, **kwargs, &block)

        name = name.to_sym

• Read up
  Read up

Method collect_response has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def collect_response(select_interval)
        now = Fluent::Clock.now
        sockets = []
        results = []
        begin

Method event has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def event(level, args)
      time = Time.now
      message = @optional_header ? @optional_header.dup : ''
      map = @optional_attrs ? @optional_attrs.dup : {}
      args.each {|a|

Method handle_stream_simple has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def handle_stream_simple(tag, es, enqueue: false)
        if @overrides_emit
          current_emit_count = @emit_count_metrics.get
          size = es.size
          key = data = nil

Method main_process has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def main_process(&block)
      if @system_config.process_name
        if @system_config.workers > 1
          Process.setproctitle("worker:#{@system_config.process_name}#{ENV['SERVERENGINE_WORKER_ID']}")
        else

Method dump_config_definition has 39 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def dump_config_definition
        dumped_config = {}
        if @argument
          argument_name, _block, options = @argument
          options[:required] = !@defaults.key?(argument_name)

Method message_handler has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def message_handler(data, sock)
      pri = nil
      text = data
      unless @parser_parse_priority
        m = SYSLOG_REGEXP.match(data)

Method compat_parameters_buffer has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def compat_parameters_buffer(conf, default_chunk_key: '')
        # return immediately if <buffer> section exists, or any buffer-related parameters don't exist
        return unless conf.elements('buffer').empty?
        return if (BUFFER_PARAMS.keys + BUFFER_TIME_SLICED_PARAMS.keys).all?{|k| !conf.has_key?(k) }

Method parameter_configuration has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def parameter_configuration(name, type = nil, **kwargs, &block)
        config_parameter_option_validate!(name, type, **kwargs, &block)

        name = name.to_sym

Method merge has 38 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def merge(other) # self is base class, other is subclass
        return merge_for_finalized(other) if self.final?

        [:param_name, :required, :multi, :alias, :configured_in_section].each do |prohibited_name|
          if overwrite?(other, prohibited_name)

Method scan_json has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def scan_json(is_array)
        result = nil
        # Yajl does not raise ParseError for incomplete json string, like '[1', '{"h"', '{"h":' or '{"h1":1'
        # This is the reason to use JSON module.

Method parse_bracket_notation has 37 lines of code (exceeds 25 allowed). Consider refactoring.

Open

        def self.parse_bracket_notation(param)
          orig_param = param
          result = []
          param = param[1..-1]
          in_bracket = false

Method build_type_converters has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def build_type_converters(types)
        return nil unless types

        converters = {}

Method setup_http_option has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def setup_http_option
      use_ssl = @endpoint.start_with?('https')
      opt = {
        open_timeout: @open_timeout,
        read_timeout: @read_timeout,

Method write_guard has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def write_guard(&block)
        begin
          block.call
        rescue Fluent::Plugin::Buffer::BufferOverflowError
          log.warn "failed to write data into buffer by buffer overflow", action: @buffer_config.overflow_action

Method configure has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def configure(conf)
      exec_filter_compat_parameters_convert!(conf)
      compat_parameters_convert(conf, :buffer)

      if inject_section = conf.elements('inject').first