class Sidekiq::Metrics::Query
def fetch_marks(time_range, granularity)
def fetch_marks(time_range, granularity) [].tap do |result| marks = @pool.with { |c| c.hgetall("#{@time.strftime("%Y%m%d")}-marks") } marks.each do |timestamp, label| time = Time.parse(timestamp) if time_range.cover? time result << MarkResult.new(time, label, Query.bkt_time_s(time, granularity)) end end end end