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