jimeh/redistat
1
0
Fork 0
mirror of https://github.com/jimeh/redistat.git synced 2026-02-18 21:06:40 +00:00
Code Issues Packages Projects Releases Wiki Activity

updated Redistat::Summary to incorporate use of write Buffer

Browse Source
This commit is contained in:
Jim Myhrberg
2011-04-15 16:45:56 +01:00
parent 3a25fcc788
commit 6c63843cd5
1 changed files with 22 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
lib/redistat/summary.rb
View File

@@ -10,31 +10,39 @@ module Redistat
:connection_ref => nil }
end
def buffer
Redistat.buffer
end
def update_all(key, stats = {}, depth_limit = nil, opts = {})
stats ||= {}
return nil if stats.size == 0
return if stats.empty?
options = default_options.merge((opts || {}).reject { |k,v| v.nil? })
depth_limit ||= key.depth
update(key, stats, depth_limit, options[:enable_grouping], options[:connection_ref], options)
update_through_buffer(key, stats, depth_limit, options)
end
def update_through_buffer(*args)
update(*args) unless buffer.store(*args)
end
def update(key, stats, depth_limit, opts)
if opts[:enable_grouping]
stats = inject_group_summaries(stats)
key.groups.each do |k|
update_key(k, stats, depth_limit, opts[:connection_ref])
k.update_index if opts[:label_indexing]
end
else
update_key(key, stats, depth_limit, opts[:connection_ref])
end
end
private
def update(key, stats, depth_limit, enable_grouping, connection_ref, options)
if enable_grouping
stats = inject_group_summaries(stats)
key.groups.each do |k|
update_key(k, stats, depth_limit, connection_ref)
k.update_index if options[:label_indexing]
end
else
update_key(key, stats, depth_limit, connection_ref)
end
end
def update_key(key, stats, depth_limit, connection_ref)
Date::DEPTHS.each do |depth|
update_fields(key, stats, depth, connection_ref)