Method run has 29 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def run
    options = {}
    unless config[:level].nil?
      options[:level] = config[:level]
    end

Method run has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def run
    response = client.search(build_request_options)
    if config[:invert]
      if response['aggregations']['average']['value'] < config[:crit]
        critical "Query average (#{response['aggregations']['average']['value']}) was below critical threshold. #{kibana_info}"

Method run has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def run
    response = client.count(build_request_options)
    if config[:invert]
      if response['count'] < config[:crit]
        critical "Query count (#{response['count']}) was below critical threshold. #{kibana_info}"

Method run has 28 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def run
    # If only one cluster is given, no need to check the indexes
    ok 'All indexes are unique' if config[:cluster].length == 1

    port = ':9200'

Method get_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method acquire_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def acquire_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method get_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method get_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method get_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method get_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method get_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method get_es_resource has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

• Read up
  Read up

Method breaker_status has a Cognitive Complexity of 10 (exceeds 5 allowed). Consider refactoring.

Open

  def breaker_status
    breakers = {}
    status = if config[:localhost]
               get_es_resource('/_nodes/_local/stats/breaker')
             else

• Read up
  Read up

Method get_es_resource has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

Method run has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def run
    fieldcounts = indexfieldcount
    limits = fieldlimitsetting

    warnings = {}

Method run has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def run
    node_fs_stats = client.nodes.stats metric: 'fs,indices'
    nodes_being_used = node_fs_stats['nodes'].values.select { |node| node['indices']['store']['size_in_bytes'] > 0 }

    # TODO: come back and cleanup all these rubocop disables with a little refactor

Method get_es_resource has 27 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def get_es_resource(resource)
    headers = {}
    if config[:user] && config[:password]
      auth = 'Basic ' + Base64.strict_encode64("#{config[:user]}:#{config[:password]}").chomp
      headers = { 'Authorization' => auth }

Method run has 26 lines of code (exceeds 25 allowed). Consider refactoring.

Open

  def run
    es_version = Gem::Version.new(acquire_es_version)

    if es_version >= Gem::Version.new('1.0.0')
      ln = get_es_resource('/_nodes/_local')

Method run has a Cognitive Complexity of 9 (exceeds 5 allowed). Consider refactoring.

Open

  def run
    stats = acquire_status

    if stats.code == 200
      if config[:all]

• Read up
  Read up

Method acquire_heap_usage has a Cognitive Complexity of 8 (exceeds 5 allowed). Consider refactoring.

Open

  def acquire_heap_usage(heap_used, heap_max, node_name)
    if config[:percentage]
      heap_usage = ((100 * heap_used) / heap_max).to_i
      output = if config[:all]
                 "Node #{node_name}: Heap used in bytes #{heap_used} (#{heap_usage}% full)\n"

• Read up
  Read up