Class: Fluent::Plugin::Opentelemetry::HttpInputHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/fluent/plugin/opentelemetry/http_input_handler.rb

Defined Under Namespace

Classes: SizeLimitError

Instance Method Summary collapse

Constructor Details

#initialize(http_config, logger) ⇒ HttpInputHandler

Returns a new instance of HttpInputHandler.



43
44
45
46
# File 'lib/fluent/plugin/opentelemetry/http_input_handler.rb', line 43

def initialize(http_config, logger)
  @http_config = http_config
  @logger = logger
end

Instance Method Details

#logs(req, &block) ⇒ Object



48
49
50
# File 'lib/fluent/plugin/opentelemetry/http_input_handler.rb', line 48

def logs(req, &block)
  common(req, Fluent::Plugin::Opentelemetry::Request::Logs, Fluent::Plugin::Opentelemetry::Response::Logs, &block)
end

#metrics(req, &block) ⇒ Object



52
53
54
# File 'lib/fluent/plugin/opentelemetry/http_input_handler.rb', line 52

def metrics(req, &block)
  common(req, Fluent::Plugin::Opentelemetry::Request::Metrics, Fluent::Plugin::Opentelemetry::Response::Metrics, &block)
end

#traces(req, &block) ⇒ Object



56
57
58
# File 'lib/fluent/plugin/opentelemetry/http_input_handler.rb', line 56

def traces(req, &block)
  common(req, Fluent::Plugin::Opentelemetry::Request::Traces, Fluent::Plugin::Opentelemetry::Response::Traces, &block)
end