Initial metrics and traces providers.

config/metrics.rb

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

config/sus.rb

@@ -6,4 +6,10 @@
 require "covered/sus"
 include Covered::Sus
 
-ENV["CONSOLE_LEVEL"] ||= "fatal"
+# ENV["CONSOLE_LEVEL"] ||= "fatal"
+
+ENV["TRACES_BACKEND"] ||= "traces/backend/test"
+require 'traces'
+
+ENV["METRICS_BACKEND"] ||= "metrics/backend/test"
+require 'metrics'

config/traces.rb

@@ -0,0 +1,9 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024, by Samuel Williams.
+
+def prepare
+	require 'traces/provider/async/task'
+	# require 'traces/provider/async/scheduler'
+end

gems.rb

@@ -25,6 +25,9 @@
 	gem "decode"
 	gem "rubocop"
 
+	gem "traces"
+	gem "metrics"
+
 	gem "sus-fixtures-async"
 	gem "sus-fixtures-console", "~> 0.3"
 

lib/metrics/provider/async.rb

@@ -0,0 +1,6 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024, by Samuel Williams.
+
+require_relative 'async/task'

lib/metrics/provider/async/task.rb

@@ -0,0 +1,17 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024, by Samuel Williams.
+
+require_relative '../../../async/task'
+require 'metrics/provider'
+
+Metrics::Provider(Async::Task) do
+	ASYNC_TASK_SCHEDULED = Metrics.metric("async.task.scheduled", :counter, description: "The number of tasks scheduled.")
+
+	def schedule(&block)
+		ASYNC_TASK_SCHEDULED.emit(1)
+
+		super(&block)
+	end
+end

lib/traces/provider/async.rb

@@ -0,0 +1,6 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024, by Samuel Williams.
+
+require_relative 'async/task'

lib/traces/provider/async/scheduler.rb

@@ -0,0 +1,88 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024, by Samuel Williams.
+
+require_relative '../../../async/scheduler'
+require 'traces/provider'
+
+# Traces::Provider(Async::Scheduler) do
+# 	def yield
+# 		Traces.trace("async.scheduler.yield") {super}
+# 	end
+
+# 	def block(blocker, timeout)
+# 		attributes = {
+# 			blocker: blocker.to_s,
+# 			timeout: timeout
+# 		}
+
+# 		Traces.trace("async.scheduler.block", attributes: attributes) {super}
+# 	end
+
+# 	def transfer
+# 		Traces.trace("async.scheduler.transfer") {super}
+# 	end
+
+# 	# @asynchronous May be non-blocking..
+# 	def address_resolve(hostname)
+# 		attributes = {
+# 			hostname: hostname
+# 		}
+
+# 		Traces.trace("async.scheduler.address_resolve", attributes: attributes) {super}
+# 	end
+
+# 	def io_wait(io, events, timeout = nil)
+# 		attributes = {
+# 			io: io.to_s,
+# 			events: events,
+# 			timeout: timeout
+# 		}
+
+# 		Traces.trace("async.scheduler.io_wait", attributes: attributes) {super}
+# 	end
+
+# 	if Async::Scheduler.method_defined?(:io_read)
+# 		def io_read(io, buffer, length, offset = 0)
+# 			attributes = {
+# 				io: io.to_s,
+# 				buffer: buffer,
+# 				length: length,
+# 				offset: offset,
+# 			}
+
+# 			Traces.trace("async.scheduler.io_read", attributes: attributes) {super}
+# 		end
+# 	end
+
+# 	if Async::Scheduler.method_defined?(:io_write)
+# 		def io_write(io, buffer, length, offset = 0)
+# 			attributes = {
+# 				io: io.to_s,
+# 				buffer: buffer,
+# 				length: length,
+# 				offset: offset,
+# 			}
+
+# 			Traces.trace("async.scheduler.io_write", attributes: attributes) {super}
+# 		end
+# 	end
+
+# 	def process_wait(pid, flags)
+# 		attributes = {
+# 			pid: pid,
+# 			flags: flags
+# 		}
+
+# 		Traces.trace("async.scheduler.process_wait", attributes: attributes) {super}
+# 	end
+
+# 	def with_timeout(duration, exception = Async::TimeoutError, message = "execution expired", &block)
+# 		attributes = {
+# 			duration: duration,
+# 		}
+
+# 		Traces.trace("async.scheduler.with_timeout", attributes: attributes) {super}
+# 	end
+# end

lib/traces/provider/async/task.rb

@@ -0,0 +1,27 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2022, by Samuel Williams.
+
+require_relative '../../../async/task'
+require 'traces/provider'
+
+Traces::Provider(Async::Task) do
+	def schedule(&block)
+		unless self.transient?
+			trace_context = Traces.trace_context
+		end
+
+		super do
+			Traces.trace_context = trace_context
+
+			attributes = {
+				"annotation" => self.annotation,
+			}
+
+			Traces.trace('async.task', attributes: attributes) do
+				yield
+			end
+		end
+	end
+end