Method: Gitlab::ReactiveCacheSetCache#clear_cache!

Defined in:

lib/gitlab/reactive_cache_set_cache.rb

#clear_cache!(key) ⇒ Object

# File 'lib/gitlab/reactive_cache_set_cache.rb', line 13

def clear_cache!(key)
  with do |redis|
    keys = read(key).map { |value| "#{cache_namespace}:#{value}" }
    keys << cache_key(key)

    Gitlab::Instrumentation::RedisClusterValidator.allow_cross_slot_commands do
      if Gitlab::Redis::ClusterUtil.cluster?(redis)
        Gitlab::Redis::ClusterUtil.batch_unlink(keys, redis)
      else
        redis.pipelined do |pipeline|
          keys.each_slice(1000) { |subset| pipeline.unlink(*subset) }
        end
      end
    end
  end
end