Ccp::Kvs.set! for fast access

lib/ccp/kvs/core.rb

@@ -3,6 +3,7 @@ module Kvs
     module Core
       def get(k)   ; raise NotImplementedError, "subclass resposibility"; end
       def set(k,v) ; raise NotImplementedError, "subclass resposibility"; end
+      def set!(k,v); raise NotImplementedError, "subclass resposibility"; end
       def del(k)   ; raise NotImplementedError, "subclass resposibility"; end
       def keys     ; raise NotImplementedError, "subclass resposibility"; end
       def exist?(k); !! get(k)                                          ; end

lib/ccp/kvs/hash.rb

@@ -11,6 +11,7 @@ def initialize
 
       def get(k)   ; decode(@db[k.to_s])         ; end
       def set(k,v) ; @db[k.to_s] = encode(v).to_s; end
+      def set!(k,v); set(k,v)                    ; end
       def del(k)   ; decode(@db.delete(k.to_s))  ; end
       def count    ; @db.size                    ; end
       def clear    ; @db.clear                   ; end

lib/ccp/kvs/kch.rb

@@ -13,6 +13,7 @@ class Kch < Kyoto::Cabinet
         # core
         def get(k)        ; R{ super }; end
         def set(k,v)      ; W{ super }; end
+        def set!(k,v)     ;    super  ; end
         def del(k)        ; W{ super }; end
         def count         ; R{ super }; end
         def read          ; R{ super }; end

lib/ccp/kvs/kyoto/cabinet.rb

@@ -31,6 +31,12 @@ def set(k,v)
             kyoto_error!("set(%s): " % k)
         end
 
+        def set!(k,v)
+          val = encode(v)
+          @db[k.to_s] = val or
+            kyoto_error!("set!(%s): " % k)
+        end
+
         def del(k)
           tryW("del")
           v = @db[k.to_s]

lib/ccp/kvs/tch.rb

@@ -13,6 +13,7 @@ class Tch < Tokyo::Cabinet
         # core
         def get(k)        ; R{ super }; end
         def set(k,v)      ; W{ super }; end
+        def set!(k,v)     ;    super  ; end
         def del(k)        ; W{ super }; end
         def count         ; R{ super }; end
         def read          ; R{ super }; end

lib/ccp/kvs/tokyo/cabinet.rb

@@ -33,6 +33,12 @@ def set(k,v)
             tokyo_error!("set(%s): " % k)
         end
 
+        def set!(k,v)
+          val = encode(v)
+          @db[k.to_s] = val or
+            tokyo_error!("set!(%s): " % k)
+        end
+
         def del(k)
           tryW("del")
           v = @db[k.to_s]

lib/ccp/version.rb

@@ -1,3 +1,3 @@
 module Ccp
-  VERSION = "0.5.0"
+  VERSION = "0.5.1"
 end

spec/kvs/core_spec.rb

@@ -7,6 +7,7 @@
   it { should respond_to("ext") }
   it { should respond_to("get") }
   it { should respond_to("set") }
+  it { should respond_to("set!") }
   it { should respond_to("del") }
   it { should respond_to("keys") }
   it { should respond_to("touch") }

spec/kvs/kvs_spec.rb

@@ -111,5 +111,15 @@
         kvs.codec!(:msgpack).should == kvs
       end
     end
+
+    describe "#set!" do
+      specify do
+        kvs.W! if klass.ext != "hash"
+        kvs.codec! :json
+        kvs.count.should == 0
+        kvs.set!("a", 1)
+        kvs["a"].should == 1
+      end
+    end
   end
 end