File output.rb has 1290 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fluent/env'
require 'fluent/error'
require 'fluent/plugin/base'
require 'fluent/plugin/buffer'
require 'fluent/plugin_helper/record_accessor'

Method generate has a Cognitive Complexity of 138 (exceeds 5 allowed). Consider refactoring.

Open

      def self.generate(proxy, conf, logger, plugin_class, stack = [], strict_config_value = false)
        return nil if conf.nil?

        section_stack = ""
        unless stack.empty?

• Read up
  Read up

File in_tail.rb has 1092 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'cool.io'

require 'fluent/plugin/input'
require 'fluent/config/error'
require 'fluent/event'

File supervisor.rb has 1016 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fileutils'
require 'open3'
require 'pathname'

require 'fluent/config'

Method write_step_by_step has a Cognitive Complexity of 111 (exceeds 5 allowed). Consider refactoring.

Open

      def write_step_by_step(metadata, data, format, splits_count, &block)
        splits = []
        if splits_count > data.size
          splits_count = data.size
        end

• Read up
  Read up

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

Open

      def configure(conf)
        unless implement?(:synchronous) || implement?(:buffered) || implement?(:delayed_commit)
          raise "BUG: output plugin must implement some methods. see developer documents."
        end

• Read up
  Read up

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

Open

    def start
      super

      log.info "listening tcp socket", bind: @bind, port: @port
      del_size = @delimiter.length

• Read up
  Read up

File buffer.rb has 719 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fluent/plugin/base'
require 'fluent/plugin/owned_by_mixin'
require 'fluent/plugin_id'
require 'fluent/plugin_helper'
require 'fluent/unique_id'

File out_forward.rb has 649 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fluent/output'
require 'fluent/config/error'
require 'fluent/clock'
require 'fluent/tls'
require 'base64'

Method parse_element has a Cognitive Complexity of 70 (exceeds 5 allowed). Consider refactoring.

Open

      def parse_element(root_element, elem_name, attrs = {}, elems = [])
        while true
          spacing
          if eof?
            if root_element

• Read up
  Read up

File server.rb has 624 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fluent/plugin_helper/event_loop'

require 'serverengine'
require 'cool.io'
require 'socket'

Class Output has 73 methods (exceeds 20 allowed). Consider refactoring.

Open

    class Output < Base
      include PluginId
      include PluginLoggerMixin
      include PluginHelper::Mixin
      include UniqueId::Mixin

File log.rb has 587 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'forwardable'
require 'logger'

module Fluent
  class Log

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

Open

    def configure(conf)
      used_worker_ids = []
      available_worker_ids = (0..Fluent::Engine.system_config.workers - 1).to_a
      # initialize <worker> elements
      conf.elements(name: 'worker').each do |e|

• Read up
  Read up

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

Open

    def configure(conf)
      compat_parameters_convert(conf, :buffer, default_chunk_key: 'tag')

      super

• Read up
  Read up

File output.rb has 559 lines of code (exceeds 250 allowed). Consider refactoring.

Open

require 'fluent/plugin'
require 'fluent/plugin/buffer'
require 'fluent/plugin/output'
require 'fluent/plugin/bare_output'
require 'fluent/compat/call_super_mixin'

Method child_process_execute_once has a Cognitive Complexity of 56 (exceeds 5 allowed). Consider refactoring.

Open

      def child_process_execute_once(
          title, command, arguments, subprocess_name, mode, stderr, env, unsetenv, chdir,
          internal_encoding, external_encoding, scrub, replace_string, wait_timeout, on_exit_callback, &block
      )
        spawn_args = if arguments || subprocess_name

• Read up
  Read up

Method expand_paths has a Cognitive Complexity of 53 (exceeds 5 allowed). Consider refactoring.

Open

    def expand_paths
      date = Fluent::EventTime.now
      paths = []
      @paths.each { |path|
        path = if @path_timezone

• Read up
  Read up

Method socket_create_tls has a Cognitive Complexity of 51 (exceeds 5 allowed). Consider refactoring.

Open

      def socket_create_tls(
          host, port,
          version: Fluent::TLS::DEFAULT_VERSION, min_version: nil, max_version: nil, ciphers: Fluent::TLS::CIPHERS_DEFAULT, insecure: false, verify_fqdn: true, fqdn: nil,
          enable_system_cert_store: true, allow_self_signed_cert: false, cert_paths: nil,
          cert_path: nil, private_key_path: nil, private_key_passphrase: nil,

• Read up
  Read up

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

Open

    def configure(conf)
      super

      regexp_and_conditions = {}
      regexp_or_conditions = {}

• Read up
  Read up