Sha256: 2a7406c3372a6b431c5819b87f3cd9971175194b8d916ac9194e4735f02b7e13
Contents?: true
Size: 781 Bytes
Versions: 16
Compression:
Stored size: 781 Bytes
Contents
class ProconBypassMan::Procon::PerformanceMeasurement::QueueOverProcess
extend ProconBypassMan::CanOverProcess
include Singleton
attr_reader :distributed_queue
# @override
def self.enable?
ProconBypassMan.config.enable_procon_performance_measurement?
end
# @override
def self.distributed_class
ProconBypassMan::Procon::PerformanceMeasurement::SpanQueue
end
# @override
def self.socket_file_path
"/tmp/procon_bypass_man_procon_performance_queue".freeze
end
def self.push(value)
return unless enable?
instance.distributed_queue.push(value)
end
def self.pop
return unless enable?
instance.distributed_queue.pop
end
def initialize
@distributed_queue = DRbObject.new_with_uri(self.class.socket_path)
end
end
Version data entries
16 entries across 16 versions & 1 rubygems