app/models/snapshot.rb spec/config/single.conf @@ -10,6 +10,8 @@ class Server include DataMapper::Resource + has n, :snapshots + property :id, Serial property :name, String, :key => true property :host, String @@ -35,6 +37,19 @@ class Server end end + def write_statistics + if alive? + self.snapshots.create :alive => true, + :used_memory => used_memory.to_i, + :total_connections_received => total_connections_received.to_i, + :total_commands_processed => total_commands_processed.to_i, + :connected_clients => connected_clients.to_i, + :created_at => Time.now + else + self.snapshots.create :alive => false, :created_at => Time.now + end + end + def alive? return true if stats rescue app/models/server.rb @@ -39,11 +39,23 @@ describe "Server" do end it "should return a status" do - server = Server.new attributes - server.should_not be_alive + server.should be_alive + end + + it "should write statistics for active server" do + lambda { server.write_statistics }.should change { server.snapshots.size }.by(1) + end + + it "should write statistics for dead server" do + server = Server.create attributes(:port => "6380") + lambda { server.write_statistics }.should change { server.snapshots.size }.by(1) end private + def server + @server ||= Server.first + end + def attributes(options = {}) { :name => "master", :host => "127.0.0.1", :port => "6379" }.merge(options) end spec/app/models/server_spec.rb @@ -9,5 +9,6 @@ require "#{root}/memoria" Memoria.new(File.join(File.dirname(__FILE__), '..', 'memoria.yml')) DataMapper.auto_migrate! +Server.create! :name => "single", :host => "127.0.0.1", :port => "6379" set :views, "#{root}/views" spec/env.rb @@ -14,3 +14,22 @@ task :files do puts "Files:\n #{Dir['**/*'].reject {|f| File.directory?(f)}.sort.inspect}" puts "Test files:\n #{Dir['spec/**/*_spec.rb'].reject {|f| File.directory?(f)}.sort.inspect}" end + +namespace :redis do + desc 'Start the Redis cluster' + task :start => :clean do + system "redis-server spec/config/single.conf" + end + + desc 'Stop the Redis cluster' + task :stop do + # TODO replace with: + # system "kill -9 `tmp/redis-single.pid`" + system "ps -eo pid,comm | grep redis | xargs kill -9" + end + + desc 'Clean the tmp/ directory' + task :clean do + system "rm tmp/*" rescue nil + end +end tasks/gem.rake 8b03a868b47bee80b6b9fbf2c21ae239a7b07313 Luca Guidi guidi.luca@gmail.com http://github.com/jodosha/memoria/commit/cbfea45ea07e9c94d80b126d8b23e5021d40e84c cbfea45ea07e9c94d80b126d8b23e5021d40e84c 2009-06-14T10:41:57-07:00 2009-06-14T10:41:57-07:00 Write statistics on the database 9a380daba05064a5fc11a831c288a2bbdedfd807 Luca Guidi guidi.luca@gmail.com