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 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

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 socket_option_set has 36 lines of code (exceeds 25 allowed). Consider refactoring.

Open

      def socket_option_set(sock, resolve_name: nil, nonblock: false, linger_timeout: nil, recv_timeout: nil, send_timeout: nil, receive_buffer_size: nil, send_keepalive_packet: nil)
        unless resolve_name.nil?
          sock.do_not_reverse_lookup = !resolve_name
        end
        if nonblock

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

Open

    def lifecycle(desc: false, kind_callback: nil, kind_or_agent_list: nil)
      only_zero_downtime_restart_ready = false

      unless kind_or_agent_list
        if @source_only_mode.enabled?

Method build_object has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def build_object(opts)
        qs = opts[:query]
        if tag = qs['tag'.freeze].first
          # ?tag= to search an output plugin by match pattern
          if obj = @agent.plugin_info_by_tag(tag, opts)

• Read up
  Read up

Method convert_values has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def convert_values(time, record)
        return time, record unless @execute_convert_values

        record.each_key do |key|
          value = record[key]

• Read up
  Read up

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

Open

    def configure(conf)
      compat_parameters_convert(conf, :parser)

      super

• Read up
  Read up

Method with_io has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

        def with_io
          if @open_on_every_update
            io = open
            begin
              yield io

• Read up
  Read up

Method on_timer has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def on_timer
      now = Fluent::EventTime.now

      array = []
      map = {}

• Read up
  Read up

Method try_rollback_all has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def try_rollback_all
        return unless @dequeued_chunks
        @dequeued_chunks_mutex.synchronize do
          until @dequeued_chunks.empty?
            info = @dequeued_chunks.shift

• Read up
  Read up

Method run_rpc_server has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def run_rpc_server
      @rpc_server = RPC::Server.new(@rpc_endpoint, $log)

      # built-in RPC for signals
      @rpc_server.mount_proc('/api/processes.interruptWorkers') { |req, res|

• Read up
  Read up

Method on_record has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

    def on_record(time, record)
      tag = extract_tag_from_record(record)
      tag = @added_prefix_string + tag if tag && @add_prefix
      tag ||= @tag
      time ||= extract_time_from_record(record) || Fluent::EventTime.now

• Read up
  Read up

Method parser_create has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def parser_create(usage: '', type: nil, conf: nil, default_type: nil)
        parser = @_parsers[usage]
        return parser if parser && !type && !conf

        type = if type

• Read up
  Read up

Method formatter_create has a Cognitive Complexity of 12 (exceeds 5 allowed). Consider refactoring.

Open

      def formatter_create(usage: '', type: nil, conf: nil, default_type: nil)
        formatter = @_formatters[usage]
        return formatter if formatter && !type && !conf

        type = if type

• Read up
  Read up

Method parse_multilines has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def parse_multilines(lines, tail_watcher)
      lb = tail_watcher.line_buffer_timer_flusher.line_buffer
      es = Fluent::MultiEventStream.new
      if @parser.has_firstline?
        tail_watcher.line_buffer_timer_flusher.reset_timer

Method create_transfer_socket has 35 lines of code (exceeds 25 allowed). Consider refactoring.

Open

    def create_transfer_socket(host, port, hostname, &block)
      case @transport
      when :tls
        socket_create_tls(
          host, port,

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

Open

    def configure(conf)
      compat_parameters_convert(conf, :parser)
      parser_config = conf.elements('parse').first
      unless parser_config
        raise Fluent::ConfigError, "<parse> section is required."