Class: Fluent::Plugin::KubernetesMetricsAggregatorInput

Inherits:
Input
  • Object
show all
Defined in:
lib/fluent/plugin/in_kubernetes_metrics_aggregator.rb

Defined Under Namespace

Classes: ResourceUsageMetricsUnit, UsageMetricsUnit

Constant Summary collapse

@@namespace_usage_metrics_map = 
{}
@@node_requests_limits_metrics_map = 
{}
@@namespace_resource_usage_metrics_map = 
{}
@@node_resource_usage_metrics_map = 
{}

Instance Method Summary collapse

Instance Method Details

#close ⇒ Object 



173
174
175
176
177
 
# File 'lib/fluent/plugin/in_kubernetes_metrics_aggregator.rb', line 173

def close
  @watchers.each &:finish if @watchers

  super
end

#configure(conf) ⇒ Object 



156
157
158
159
160
161
162
 
# File 'lib/fluent/plugin/in_kubernetes_metrics_aggregator.rb', line 156

def configure(conf)
  super
  @mutex_node_req_lim = Mutex.new
  @mutex_node_res_usage = Mutex.new
  parse_tag
  initialize_client
end

#start ⇒ Object 



164
165
166
167
168
169
170
171
 
# File 'lib/fluent/plugin/in_kubernetes_metrics_aggregator.rb', line 164

def start
  super

  timer_execute :limits_request_scraper, @interval, &method(:scrape_limits_requests_metrics)
  timer_execute :node_scraper, @interval, &method(:scrape_node_metrics)
  timer_execute :resource_usage_scraper, @interval, &method(:scrape_resource_usage_metrics)

end