Class: Rubino::API::Middleware::Observability

Inherits:
Object
  • Object
show all
Defined in:
lib/rubino/api/middleware/observability.rb

Overview

Outermost middleware. Wraps every request to:

- record http_requests_total{method,path,status} + http_request_duration_seconds
- emit one JSON log line (event="api.request") with method, path, status, duration_ms

Status comes from the response tuple after ErrorHandler has done its mapping; on a fully unhandled raise we still record status=500 and re-raise so Puma can render whatever it wants. The path metric label uses env (the matched pattern) when present, to keep Prometheus label cardinality bounded.

Instance Method Summary collapse

Constructor Details

#initialize(app, logger: nil) ⇒ Observability

Returns a new instance of Observability.



16
17
18
19
 
# File 'lib/rubino/api/middleware/observability.rb', line 16

def initialize(app, logger: nil)
  @app = app
  @logger = logger || Rubino.logger
end

Instance Method Details

#call(env) ⇒ Object 



21
22
23
24
25
26
27
28
29
 
# File 'lib/rubino/api/middleware/observability.rb', line 21

def call(env)
  start = Process.clock_gettime(Process::CLOCK_MONOTONIC)
  status, headers, body = @app.call(env)
  observe(env, status, start)
  [status, headers, body]
rescue StandardError
  observe(env, 500, start)
  raise
end