Sha256: f7b88399dfec04af83476bc81e7bbcb4019cc252dc39d523754fa979056a231b
Contents?: true
Size: 608 Bytes
Versions: 24
Compression:
Stored size: 608 Bytes
Contents
# frozen_string_literal: true
module Mnemosyne
module Probes
module Mnemosyne
module Tracer
class Probe < ::Mnemosyne::Probe
subscribe 'trace.mnemosyne'
def call(trace, _name, start, finish, _id, payload)
start = ::Mnemosyne::Clock.to_tick(start)
finish = ::Mnemosyne::Clock.to_tick(finish)
span = ::Mnemosyne::Span.new 'custom.trace',
start: start, finish: finish, meta: payload
trace << span
end
end
end
end
register nil, nil, Mnemosyne::Tracer::Probe.new
end
end
Version data entries
24 entries across 24 versions & 1 rubygems