Class: Fluent::Plugin::OpentelemetryMetricsInput

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

Defined Under Namespace

Modules: Extension Classes: Metrics, MonitorInfo

Instance Method Summary collapse

Instance Method Details

#start ⇒ Object 



28
29
30
31
32
33
34
35
 
# File 'lib/fluent/plugin/in_opentelemetry_metrics.rb', line 28

def start
  super

  @metrics = Metrics.new(metric_name_prefix: @metric_name_prefix)
  timer_execute(:in_opentelemetry_metrics, @emit_interval) do
    router.emit(@tag, Fluent::EventTime.now, { "type" => Opentelemetry::RECORD_TYPE_METRICS, "message" => @metrics.record })
  end
end