Sha256: 98bbe1611c979645744ee64827fb981afc7a3a0ddcb3a5e9881684ed838a5fde
Contents?: true
Size: 1.21 KB
Versions: 8
Compression:
Stored size: 1.21 KB
Contents
# frozen_string_literal: true
module Sidekiq
module Throttled
# Queue name utility belt.
#
# @private
module QueueName
# RegExp used to stip out any redisr-namespace prefixes with `queue:`.
QUEUE_NAME_PREFIX_RE = %r{.*queue:}.freeze
private_constant :QUEUE_NAME_PREFIX_RE
class << self
# Strips redis-namespace and `queue:` prefix from given queue name.
#
# @example
#
# QueueName.normalize "queue:default"
# # => "default"
#
# QueueName.normalize "queue:queue:default"
# # => "default"
#
# QueueName.normalize "foo:bar:queue:default"
# # => "default"
#
# @param [#to_s]
# @return [String]
def normalize(queue)
-queue.to_s.sub(QUEUE_NAME_PREFIX_RE, "")
end
# Prepends `queue:` prefix to given `queue` name.
#
# @note It does not normalizes queue before expanding it, thus
# double-call of this method will potentially do some harm.
#
# @param [#to_s] queue Queue name
# @return [String]
def expand(queue)
-"queue:#{queue}"
end
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems