Sha256: ee69607793f62eec8e64d0a608f56f706a89fb35079f8a01cf818bae3bb61cbb
Contents?: true
Size: 1.2 KB
Versions: 8
Compression:
Stored size: 1.2 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 = /^.*queue:/
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 [String]
# @return [String]
def normalize(queue)
queue.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 [String] 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