Contents

# frozen_string_literal: true

require_relative 'base_data'

module Fluent
  module Plugin
    module ElasticsearchStats
      class DanglingData < BaseData
        NAME = 'dangling'

        def extract_metrics
          generate_dangling_indices_count
        end

        def generate_dangling_indices_count
          metrics = []
          metrics << metric.format(name: %w[dangling_indices count],
                                   value: dangling_indices.size,
                                   family: family,
                                   metadata: metadata)
          metrics
        end

        private

        def dangling_indices
          data.fetch('dangling_indices', [])
        end
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
fluent-plugin-elasticsearch-stats-0.6.0	lib/fluent/plugin/elasticsearch_stats/dangling_data.rb
fluent-plugin-elasticsearch-stats-0.5.0	lib/fluent/plugin/elasticsearch_stats/dangling_data.rb
fluent-plugin-elasticsearch-stats-0.4.0	lib/fluent/plugin/elasticsearch_stats/dangling_data.rb
fluent-plugin-elasticsearch-stats-0.3.0	lib/fluent/plugin/elasticsearch_stats/dangling_data.rb
fluent-plugin-elasticsearch-stats-0.2.0	lib/fluent/plugin/elasticsearch_stats/dangling_data.rb