Sha256: 15bc63671433d992b8f1fbae9551b8b0f3ab015b748415cb498bc43db70112b0
Contents?: true
Size: 575 Bytes
Versions: 1
Compression:
Stored size: 575 Bytes
Contents
module Sidekiq module Cluster module Memory class << self attr_accessor :strategies def offenders(worker_pool) name = worker_pool.config.memory_strategy.to_sym strategies[name].new(worker_pool).offenders end end self.strategies ||= {} module MemoryStrategy def self.included(base) ::Sidekiq::Cluster::Memory.strategies[base.name.gsub(/.*::/, '').downcase.to_sym] = base end end end end end require_relative 'memory/individual' require_relative 'memory/total'
Version data entries
1 entries across 1 versions & 1 rubygems
Version | Path |
---|---|
sidekiq-cluster-0.1.2 | lib/sidekiq/cluster/memory.rb |