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 



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

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

  super
end

#configure(conf) ⇒ Object 



149
150
151
152
153
154
155
 
# File 'lib/fluent/plugin/in_kubernetes_metrics_aggregator.rb', line 149

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

#start ⇒ Object 



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

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