Metrics for client and server.

Author: ioquatix

config/metrics.rb

@@ -0,0 +1,8 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2025, by Samuel Williams.
+
+def prepare
+	require "metrics/provider/async/http"
+end

config/sus.rb

@@ -9,5 +9,16 @@
 require "covered/sus"
 include Covered::Sus
 
-require "traces"
 ENV["TRACES_BACKEND"] ||= "traces/backend/test"
+ENV["METRICS_BACKEND"] ||= "metrics/backend/test"
+
+def prepare_instrumentation!
+	require "traces"
+	require "metrics"
+end
+
+def before_tests(...)
+	prepare_instrumentation!
+	
+	super
+end

lib/metrics/provider/async/http.rb

@@ -0,0 +1,4 @@
+# frozen_string_literal: true
+
+require_relative "http/client"
+require_relative "http/server"

lib/metrics/provider/async/http/client.rb

@@ -0,0 +1,26 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2025, by Samuel Williams.
+
+require_relative "../../../../async/http/client"
+require "metrics/provider"
+
+Metrics::Provider(Async::HTTP::Client) do
+	ASYNC_HTTP_CLIENT_REQUEST_INITIATED = Metrics.metric("async.http.client.request.initiated", :counter, description: "The number of HTTP client requests initiated.")
+	ASYNC_HTTP_CLIENT_REQUEST_COMPLETED = Metrics.metric("async.http.client.request.completed", :counter, description: "The number of HTTP client requests completed.")
+	
+	def make_response(request, connection, attempt)
+		ASYNC_HTTP_CLIENT_REQUEST_INITIATED.emit(1, tags: ["method:#{request.method}"])
+		
+		response = super(request, connection, attempt)
+		
+		ASYNC_HTTP_CLIENT_REQUEST_COMPLETED.emit(1, tags: ["method:#{request.method}", "status:#{response.status}"])
+		
+		return response
+	ensure
+		unless response
+			ASYNC_HTTP_CLIENT_REQUEST_COMPLETED.emit(1, tags: ["method:#{request.method}", "status:failed"])
+		end
+	end
+end

lib/metrics/provider/async/http/server.rb

@@ -0,0 +1,26 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2025, by Samuel Williams.
+
+require_relative "../../../../async/http/server"
+require "metrics/provider"
+
+Metrics::Provider(Async::HTTP::Server) do
+	ASYNC_HTTP_SERVER_REQUEST_INITIATED = Metrics.metric("async.http.server.request.initiated", :counter, description: "The number of HTTP server requests initiated.")
+	ASYNC_HTTP_SERVER_REQUEST_COMPLETED = Metrics.metric("async.http.server.request.completed", :counter, description: "The number of HTTP server requests completed.")
+
+	def call(request)
+		ASYNC_HTTP_SERVER_REQUEST_INITIATED.emit(1, tags: ["method:#{request.method}"])
+		
+		response = super(request)
+		
+		ASYNC_HTTP_SERVER_REQUEST_COMPLETED.emit(1, tags: ["method:#{request.method}", "status:#{response.status}"])
+		
+		return response
+	ensure
+		unless response
+			ASYNC_HTTP_SERVER_REQUEST_COMPLETED.emit(1, tags: ["method:#{request.method}", "status:failed"])
+		end
+	end
+end