module Ccp::Kvs::Core
Public Class Methods
ext()
click to toggle source
# File lib/ccp/kvs/core.rb, line 30 def self.ext; name.split(/::/).last.to_s.downcase; end
included(klass)
click to toggle source
# File lib/ccp/kvs/core.rb, line 28 def self.included(klass) klass.class_eval do def self.ext; name.split(/::/).last.to_s.downcase; end def self.open(*args); new.tap{|kvs| kvs.open(*args)}; end end end
open(*args)
click to toggle source
# File lib/ccp/kvs/core.rb, line 31 def self.open(*args); new.tap{|kvs| kvs.open(*args)}; end
Public Instance Methods
[](k)
click to toggle source
# File lib/ccp/kvs/core.rb, line 17 def [](k) ; get(k) ; end
[]=(k,v)
click to toggle source
# File lib/ccp/kvs/core.rb, line 18 def []=(k,v) ; set(k,v) ; end
clear()
click to toggle source
# File lib/ccp/kvs/core.rb, line 38 def clear ; keys.each{|k| del(k)} ; end
close()
click to toggle source
# File lib/ccp/kvs/core.rb, line 12 def close ; end
codec()
click to toggle source
# File lib/ccp/kvs/core.rb, line 22 def codec ; @codec ; end
codec!(c)
click to toggle source
# File lib/ccp/kvs/core.rb, line 23 def codec!(c); @codec = Ccp::Serializers[c] ; self ; end
count()
click to toggle source
# File lib/ccp/kvs/core.rb, line 14 def count ; end
decode(v)
click to toggle source
# File lib/ccp/kvs/core.rb, line 25 def decode(v); (v && @codec) ? @codec.decode(v) : v ; end
del(k)
click to toggle source
# File lib/ccp/kvs/core.rb, line 6 def del(k) ; raise NotImplementedError, "subclass resposibility"; end
encode(v)
click to toggle source
# File lib/ccp/kvs/core.rb, line 24 def encode(v); @codec ? @codec.encode(v) : v ; end
exist?(k)
click to toggle source
# File lib/ccp/kvs/core.rb, line 8 def exist?(k); !! get(k) ; end
ext()
click to toggle source
# File lib/ccp/kvs/core.rb, line 27 def ext; self.class.name.split(/::/).last.to_s.downcase; end
get(k)
click to toggle source
# File lib/ccp/kvs/core.rb, line 4 def get(k) ; raise NotImplementedError, "subclass resposibility"; end
key?(k)
click to toggle source
# File lib/ccp/kvs/core.rb, line 9 def key?(k) ; exist?(k) ; end
keys()
click to toggle source
# File lib/ccp/kvs/core.rb, line 7 def keys ; raise NotImplementedError, "subclass resposibility"; end
open(*)
click to toggle source
# File lib/ccp/kvs/core.rb, line 11 def open(*) ; end
out(k)
click to toggle source
# File lib/ccp/kvs/core.rb, line 20 def out(k) ; del(k) ; end
put(k,v)
click to toggle source
# File lib/ccp/kvs/core.rb, line 19 def put(k,v) ; set(k,v) ; end
read()
click to toggle source
bulk operation
# File lib/ccp/kvs/core.rb, line 36 def read ; keys.inject({}){|h,k| h[k] = get(k); h } ; end
set(k,v)
click to toggle source
# File lib/ccp/kvs/core.rb, line 5 def set(k,v) ; raise NotImplementedError, "subclass resposibility"; end
source()
click to toggle source
# File lib/ccp/kvs/core.rb, line 13 def source ; @source; end
touch()
click to toggle source
# File lib/ccp/kvs/core.rb, line 15 def touch ; end
write(h)
click to toggle source
# File lib/ccp/kvs/core.rb, line 37 def write(h) ; h.each_pair{|k,v| set(k,v)} ; end