Class: RailsPerformance::DataSource

Inherits:
Object
  • Object
show all
Defined in:
lib/rails_performance/data_source.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(q: {}) ⇒ DataSource

Returns a new instance of DataSource.



5
6
7
8
9
10
# File 'lib/rails_performance/data_source.rb', line 5

def initialize(q: {})
  q[:on] ||= Date.today
  @q       = q

  #puts "  [DataSource Q]  -->  #{@q.inspect}\n\n"

end

Instance Attribute Details

#qObject (readonly)

Returns the value of attribute q.



3
4
5
# File 'lib/rails_performance/data_source.rb', line 3

def q
  @q
end

Instance Method Details

#add_to(storage = RP::Models::Collection.new) ⇒ Object



24
25
26
27
28
29
# File 'lib/rails_performance/data_source.rb', line 24

def add_to(storage = RP::Models::Collection.new)
  store do |record|
    storage.add(record)
  end
  storage
end

#dbObject



12
13
14
15
16
17
18
# File 'lib/rails_performance/data_source.rb', line 12

def db
  result = RP::Models::Collection.new
  (RP::Utils.days + 1).times do |e|
    RP::DataSource.new(q: self.q.merge({ on: e.days.ago.to_date })).add_to(result)
  end
  result
end

#default?Boolean

Returns:

  • (Boolean)


20
21
22
# File 'lib/rails_performance/data_source.rb', line 20

def default?
  @q.keys == [:on]
end

#storeObject



31
32
33
34
35
36
37
38
39
# File 'lib/rails_performance/data_source.rb', line 31

def store
  keys, values = Utils.fetch_from_redis(query)

  return [] if keys.blank?

  keys.each_with_index do |key, index|
    yield RP::Models::Record.new(key, values[index])
  end
end