Contents

# frozen_string_literal: true

require_relative 'base_data'

module Fluent
  module Plugin
    module ElasticsearchStats
      class IndicesStatsData < BaseData
        NAME = 'indices_stats'

        def extract_metrics
          extract_all_metrics + extract_indices_metrics
        end

        def extract_all_metrics
          return [] if !_all || _all.empty?

          metrics = []
          flattened = Utils.hash_flatten_keys(_all, separator: metric.name_separator)
          flattened.each do |k, v|
            metrics << metric.format(name: ['all_indices', k], value: v, family: family, metadata: metadata)
          end
          metrics.compact
        end

        private

        def _all
          data['_all']
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

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