Module: EmRiak::Util

Extended by:
Util
Included in:
Util
Defined in:
lib/em-riak/utils.rb

Instance Method Summary collapse

Instance Method Details

#clean_bucket(bucket_name) ⇒ Object



4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
# File 'lib/em-riak/utils.rb', line 4

def clean_bucket(bucket_name)
    keys=EmRiak::MapReduce.submit([:clean_bucket,{"bucket"=>bucket_name}])
    if keys
        if !(keys.class==Hash && keys[:error]) 
            keys=keys[0] if keys.class==Array && keys.count==1
            keys.each{|key| 
                key=key[0].to_s.gsub("\\","\/")
                EmRiak.destroy(URI.escape(key[0]).to_s)
                EmRiak.destroy(URI.escape(":#{key[0]}").to_s)
            }
            puts "clean done" 
        else 
            puts "Something went wrong." if EmRiak.debug
        end
    else
        puts "key empty" 
    end
end