Contents

# frozen_string_literal: true

module AsyncStorage
  module_function

  def flush_all
    keys.inject(0) do |total, (key, cli)|
      total + cli.del(key)
    end
  end

  def keys
    Enumerator.new do |yielder|
      redis_pool.with do |cli|
        cli.keys("#{config.namespace}:*").each { |key| yielder.yield(key, cli) }
      end
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
async_storage-0.0.4	lib/async_storage/bath_actions.rb
async_storage-0.0.3	lib/async_storage/bath_actions.rb
async_storage-0.0.2	lib/async_storage/bath_actions.rb
async_storage-0.0.1	lib/async_storage/bath_actions.rb