Sha256: 6d7552a4410c283e2cc7082f3193d1ce74f8fd53148bcad1a4f0400880060d09
Contents?: true
Size: 1.6 KB
Versions: 8
Compression:
Stored size: 1.6 KB
Contents
require 'daybreak'
module Moneta
module Adapters
# Daybreak backend
# @api public
class Daybreak
include Defaults
include DBMAdapter
include IncrementSupport
include CreateSupport
include EachKeySupport
# @param [Hash] options
# @option options [String] :file Database file
# @option options [::Daybreak] :backend Use existing backend instance
def initialize(options = {})
@backend = options[:backend] ||
begin
raise ArgumentError, 'Option :file is required' unless options[:file]
::Daybreak::DB.new(options[:file], serializer: ::Daybreak::Serializer::None)
end
end
# (see Proxy#load)
def load(key, options = {})
@backend.load if options[:sync]
@backend[key]
end
# (see Proxy#store)
def store(key, value, options = {})
@backend[key] = value
@backend.flush if options[:sync]
value
end
# (see Proxy#increment)
def increment(key, amount = 1, options = {})
@backend.lock { super }
end
# (see Proxy#create)
def create(key, value, options = {})
@backend.lock { super }
end
# (see Proxy#merge!)
def merge!(pairs, options = {})
if block_given?
@backend.lock do
@backend.update(pairs.map do |key, new_value|
new_value = yield(key, load(key), new_value) if key?(key)
[key, new_value]
end)
end
else
@backend.update(pairs)
end
self
end
end
end
end
Version data entries
8 entries across 8 versions & 1 rubygems