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