module Rrq
  class Keys
    def self.queues
      "rrq:queues"
    end

    def self.partitions_for(name)
      "rrq:queue:#{name}:all_partitions"
    end

    def self.active_partitions_for(name)
      "rrq:queue:#{name}:active_partitions"
    end

    def self.queue(name, partition)
      "rrq:queue:#{name}:#{partition}"
    end

    def self.working_queue(name, partition)
      "#{queue(name, partition)}:working"
    end
  end
end