Module: Clockwork
Defined Under Namespace
Classes: ClockworkEvent, FailedToParse, NoHandlerDefined
Instance Method Summary
collapse
Instance Method Details
#clear! ⇒ Object
102
103
104
105
|
# File 'lib/clockwork.rb', line 102
def clear!
@@events = []
@@handler = nil
end
|
#every(period, job, options = {}, &block) ⇒ Object
70
71
72
73
74
75
|
# File 'lib/clockwork.rb', line 70
def every(period, job, options={}, &block)
event = ClockworkEvent.new(period, job, block || get_handler, options)
@@events ||= []
@@events << event
event
end
|
#get_handler ⇒ Object
65
66
67
68
|
# File 'lib/clockwork.rb', line 65
def get_handler
raise NoHandlerDefined unless (defined?(@@handler) and @@handler)
@@handler
end
|
#handler(&block) ⇒ Object
59
60
61
|
# File 'lib/clockwork.rb', line 59
def handler(&block)
@@handler = block
end
|
#log(msg) ⇒ Object
85
86
87
|
# File 'lib/clockwork.rb', line 85
def log(msg)
puts msg
end
|
#run ⇒ Object
77
78
79
80
81
82
83
|
# File 'lib/clockwork.rb', line 77
def run
log "Starting clock for #{@@events.size} events: [ " + @@events.map { |e| e.to_s }.join(' ') + " ]"
loop do
tick
sleep 1
end
end
|
#tick(t = Time.now) ⇒ Object
89
90
91
92
93
94
95
96
97
98
99
100
|
# File 'lib/clockwork.rb', line 89
def tick(t=Time.now)
to_run = @@events.select do |event|
event.time?(t)
end
to_run.each do |event|
log "Triggering #{event}"
event.run(t)
end
to_run
end
|