Ruby in memory processing "cache", used to replace Redis.

cache.rb

require 'thread_safe'

# A process wide cache for in memory computing
class MX::Core::Cache

  def self.init!
    @data = ThreadSafe::Cache.new unless @data
  end

  def self.truncate!
    @data = ThreadSafe::Cache.new if Rails.env.test?
  end

  def self.destroy_bucket(keyspace)
    @data[keyspace] = nil
  end

  def self.add(bucket='default', key, value)
    # puts "add [#{value}] to #{bucket}:#{key}"
    @data[bucket] = ThreadSafe::Cache.new unless @data[bucket]
    if @data[bucket][key]
      @data[bucket][key] += value
    else
      @data[bucket][key] = value
    end
  end

  def self.set(bucket='default', key, value)
    @data[bucket] = ThreadSafe::Cache.new unless @data[bucket]
    @data[bucket][key] = value
  end

  def self.get(bucket='default', key)
    # puts "get #{bucket}:#{key}"
    begin
      # puts "got #{@data[bucket][key]}"
      @data[bucket][key]
    rescue Exception => e
      nil
    end
  end

  def self.bucket(bucket='default')
    begin
      @data[bucket]
    rescue Exception => e
      nil
    end
  end

end