Sha256: 4a4991cb01ebdd56916ed1211966441de32cd4997fb2a2ec5c2806f2b318cdfc
Contents?: true
Size: 670 Bytes
Versions: 96
Compression:
Stored size: 670 Bytes
Contents
require 'puppet/indirector/instrumentation_listener'
class Puppet::Indirector::InstrumentationListener::Local < Puppet::Indirector::Code
desc "Undocumented."
def find(request)
Puppet::Util::Instrumentation[request.key]
end
def search(request)
Puppet::Util::Instrumentation.listeners
end
def save(request)
res = request.instance
Puppet::Util::Instrumentation[res.name] = res
nil # don't leak the listener
end
def destroy(request)
listener = Puppet::Util::Instrumentation[request.key]
raise "Listener #{request.key} hasn't been subscribed" unless listener
Puppet::Util::Instrumentation.unsubscribe(listener)
end
end
Version data entries
96 entries across 96 versions & 3 rubygems