Class: Moneta::Adapters::Riak
- Inherits:
-
Base
- Object
- Base
- Moneta::Adapters::Riak
show all
- Defined in:
- lib/moneta/adapters/riak.rb
Overview
Instance Method Summary
collapse
Methods inherited from Base
#[], #[]=, #close, #decrement, #fetch, #increment
#expires, #prefix, #raw, #with
Constructor Details
#initialize(options = {}) ⇒ Riak
17
18
19
20
21
|
# File 'lib/moneta/adapters/riak.rb', line 17
def initialize(options = {})
bucket = options.delete(:bucket) || 'moneta'
@content_type = options.delete(:content_type) || 'application/octet-stream'
@bucket = ::Riak::Client.new(options).bucket(bucket)
end
|
Instance Method Details
#clear(options = {}) ⇒ Object
47
48
49
50
51
52
|
# File 'lib/moneta/adapters/riak.rb', line 47
def clear(options = {})
@bucket.keys do |keys|
keys.each{ |key| @bucket.delete(key) }
end
self
end
|
#delete(key, options = {}) ⇒ Object
33
34
35
36
37
|
# File 'lib/moneta/adapters/riak.rb', line 33
def delete(key, options = {})
value = load(key, options)
@bucket.delete(key, options)
value
end
|
#key?(key, options = {}) ⇒ Boolean
23
24
25
|
# File 'lib/moneta/adapters/riak.rb', line 23
def key?(key, options = {})
@bucket.exists?(key, options)
end
|
#load(key, options = {}) ⇒ Object
27
28
29
30
31
|
# File 'lib/moneta/adapters/riak.rb', line 27
def load(key, options = {})
@bucket.get(key, options).raw_data
rescue ::Riak::FailedRequest => ex
nil
end
|
#store(key, value, options = {}) ⇒ Object
39
40
41
42
43
44
45
|
# File 'lib/moneta/adapters/riak.rb', line 39
def store(key, value, options = {})
obj = ::Riak::RObject.new(@bucket, key)
obj.content_type = options[:content_type] || @content_type
obj.raw_data = value
obj.store(options)
value
end
|