Contents

# frozen_string_literal: true

require_relative 'base_data'

module Fluent
  module Plugin
    module ElasticsearchStats
      class ClusterHealthData < BaseData
        NAME = 'cluster_health'

        def extract_metrics
          extract_cluster_metrics + extract_indices_metrics
        end

        private

        def extract_cluster_metrics
          data.each_with_object([]) do |(k, v), metrics|
            metrics << metric.format(name: ['cluster', k], value: v, family: family, metadata: metadata)
          end.compact
        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/cluster_health_data.rb
fluent-plugin-elasticsearch-stats-0.5.0	lib/fluent/plugin/elasticsearch_stats/cluster_health_data.rb
fluent-plugin-elasticsearch-stats-0.4.0	lib/fluent/plugin/elasticsearch_stats/cluster_health_data.rb
fluent-plugin-elasticsearch-stats-0.3.0	lib/fluent/plugin/elasticsearch_stats/cluster_health_data.rb
fluent-plugin-elasticsearch-stats-0.2.0	lib/fluent/plugin/elasticsearch_stats/cluster_health_data.rb
fluent-plugin-elasticsearch-stats-0.1.0	lib/fluent/plugin/elasticsearch_stats/cluster_health_data.rb