Class: Qfill::Strategy::TimeSlice

Inherits:
Sample show all
Defined in:
lib/qfill/strategy/time_slice.rb

Overview

Qfill::Manager.new(

:popper => popper,
:strategy_options => {
  :window_size => 20,
  :window_units => "minutes" # "days", "hours", "minutes", "seconds",
  # NOTE: pane_size/units can't be larger than the window_size/units
  :pane_size => 2
  :pane_units => "seconds" # "days", "hours", "minutes", "seconds",
},

)

Constant Summary collapse

NAME = 
:time_slice
CONVERSIONS = 
{
  %w[seconds seconds] => 1,
  %w[seconds minutes] => 60,
  %w[seconds hours] => 60 * 60,
  %w[seconds days] => 60 * 60 * 24,
  %w[minutes minutes] => 1,
  %w[minutes hours] => 60,
  %w[minutes days] => 60 * 24,
  %w[hours hours] => 1,
  %w[hours days] => 24,
  %w[days days] => 1
}.freeze

Instance Attribute Summary

Attributes inherited from Base

#added, #ratio_modifier, #tally

Instance Method Summary collapse

Methods inherited from Base

#bump!, #fill_to_ratio!, #initialize, #name, #remaining

Constructor Details

This class inherits a constructor from Qfill::Strategy::Base

Instance Method Details

#conversion ⇒ Object

Raises:

  • (ArgumentError) 


64
65
66
67
68
69
70
 
# File 'lib/qfill/strategy/time_slice.rb', line 64

def conversion
  conversion_idx = [pane_units, window_units]
  conv = CONVERSIONS[conversion_idx]
  raise ArgumentError, "pane_units: #{pane_units} must not be larger than window_units: #{window_units}" unless conv

  conv
end

#default_pusher ⇒ Object

If window_units == “minutes” and pane_units == “seconds”, and

window_size == 20 and pane_size == 2

Then there would be (20 * CONVERSIONS[[pane_units, window_units]]) / pane_size

i.e.              (20 * 60) / 2
i.e.              600 individual panes in the (time) window, where each pane is a "result"



40
41
42
43
44
45
46
 
# File 'lib/qfill/strategy/time_slice.rb', line 40

def default_pusher
  ratio = 1 / num_panes.to_f
  array = Range.new(1, num_panes).each_with_object([]) do |pane_num, arr|
    arr << { name: pane_num.to_s, ratio: ratio }
  end
  Qfill::Pusher.from_array_of_hashes(array)
end

#fill_according_to_list_ratios! ⇒ Object 



92
93
94
95
96
97
98
99
100
101
102
 
# File 'lib/qfill/strategy/time_slice.rb', line 92

def fill_according_to_list_ratios!
  # puts "#{!is_full?} && #{result.fill_count} >= #{result.max} && #{!self.popper.totally_empty?} && #{result.current_list_ratio}"
  while !is_full? && !popper.totally_empty? && (list_ratio_tuple = result.current_list_ratio) && (take = Qfill::Result.get_limit_from_max_and_ratio(result.max, list_ratio_tuple[1], remaining)) && (!result.is_full? || take == 1)
    array_to_push = popper.next_objects!(list_ratio_tuple[0], take)
    self.added = result.push(array_to_push, list_ratio_tuple[0])
    bump!
    puts "[fill_according_to_list_ratios!]#{self}[#{list_ratio_tuple[0]}][added:#{added}]" if Qfill::VERBOSE
    result.set_next_as_current!
    break if is_full?
  end
end

#fill_up_to_ratio! ⇒ Object 



80
81
82
83
84
85
86
87
88
89
90
 
# File 'lib/qfill/strategy/time_slice.rb', line 80

def fill_up_to_ratio!
  ratio = 1.0 / popper.primary.length # 1 divided by the number of queues
  max_from_list = Qfill::Result.get_limit_from_max_and_ratio(result.max, ratio, remaining)
  while !is_full? && (take = [max_from_list, remaining].min) && (!result.is_full? || take == 1) && !popper.totally_empty? && (origin_list = popper.current_list)
    array_to_push = popper.next_objects!(origin_list.name, take)
    self.added = result.push(array_to_push, origin_list.name)
    bump!
    puts "[fill_up_to_ratio!]#{self}[Added:#{added}][Max List:#{max_from_list}][ratio:#{ratio}][take:#{take}]" if Qfill::VERBOSE
    popper.set_next_as_current!
  end
end

#num_panes ⇒ Object 



72
73
74
 
# File 'lib/qfill/strategy/time_slice.rb', line 72

def num_panes
  ((window_size * conversion) / pane_size)
end

#on_fill! ⇒ Object 



18
19
20
 
# File 'lib/qfill/strategy/time_slice.rb', line 18

def on_fill!
  # NOOP
end

#pane_size ⇒ Object 



56
57
58
 
# File 'lib/qfill/strategy/time_slice.rb', line 56

def pane_size
  strategy_options[:pane_size]
end

#pane_units ⇒ Object 



60
61
62
 
# File 'lib/qfill/strategy/time_slice.rb', line 60

def pane_units
  strategy_options[:pane_units]
end

#result_max! ⇒ Object 



76
77
78
 
# File 'lib/qfill/strategy/time_slice.rb', line 76

def result_max!
  result.max = Qfill::Result.get_limit_from_max_and_ratio(primary_list_total, result.ratio, remaining)
end

#window_size ⇒ Object 



48
49
50
 
# File 'lib/qfill/strategy/time_slice.rb', line 48

def window_size
  strategy_options[:window_size]
end

#window_units ⇒ Object 



52
53
54
 
# File 'lib/qfill/strategy/time_slice.rb', line 52

def window_units
  strategy_options[:window_units]
end