Module: MiniScheduler
- Defined in:
- lib/mini_scheduler/web.rb,
lib/mini_scheduler.rb,
lib/mini_scheduler/engine.rb,
lib/mini_scheduler/manager.rb,
lib/mini_scheduler/version.rb,
app/models/mini_scheduler/stat.rb,
lib/mini_scheduler/schedule_info.rb,
lib/mini_scheduler/distributed_mutex.rb,
lib/generators/mini_scheduler/install/install_generator.rb
Overview
Defined Under Namespace
Modules: Generators, Schedule, Web
Classes: DistributedMutex, Engine, Manager, ScheduleInfo, SidekiqExceptionHandler, Stat
Constant Summary
collapse
- VERSION =
"0.16.0"
Class Method Summary
collapse
Class Method Details
.before_sidekiq_web_request(&blk) ⇒ Object
56
57
58
59
|
# File 'lib/mini_scheduler.rb', line 56
def self.before_sidekiq_web_request(&blk)
@before_sidekiq_web_request = blk if blk
@before_sidekiq_web_request
end
|
16
17
18
|
# File 'lib/mini_scheduler.rb', line 16
def self.configure
yield self
end
|
.handle_job_exception(ex, context = {}) ⇒ Object
35
36
37
38
39
40
41
|
# File 'lib/mini_scheduler.rb', line 35
def self.handle_job_exception(ex, context = {})
if job_exception_handler
job_exception_handler.call(ex, context)
else
SidekiqExceptionHandler.handle_exception(ex, context)
end
end
|
.job_exception_handler(&blk) ⇒ Object
30
31
32
33
|
# File 'lib/mini_scheduler.rb', line 30
def self.job_exception_handler(&blk)
@job_exception_handler = blk if blk
@job_exception_handler
end
|
.job_ran(&blk) ⇒ Object
51
52
53
54
|
# File 'lib/mini_scheduler.rb', line 51
def self.job_ran(&blk)
@job_ran = blk if blk
@job_ran
end
|
.redis ⇒ Object
47
48
49
|
# File 'lib/mini_scheduler.rb', line 47
def self.redis
@redis
end
|
.redis=(r) ⇒ Object
43
44
45
|
# File 'lib/mini_scheduler.rb', line 43
def self.redis=(r)
@redis = r
end
|
.skip_schedule(&blk) ⇒ Object
61
62
63
64
|
# File 'lib/mini_scheduler.rb', line 61
def self.skip_schedule(&blk)
@skip_schedule = blk if blk
@skip_schedule
end
|
.start(workers: 1) ⇒ Object
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
# File 'lib/mini_scheduler.rb', line 66
def self.start(workers: 1)
schedules = Manager.discover_schedules
Manager.discover_queues.each do |queue|
manager = Manager.new(queue: queue, workers: workers)
schedules.each do |schedule|
if schedule.queue == queue
manager.ensure_schedule!(schedule)
end
end
Thread.new do
while true
begin
if !self.skip_schedule || !self.skip_schedule.call
manager.tick
end
rescue => e
handle_job_exception(e, message: "While ticking scheduling manager")
end
sleep 1
end
end
end
end
|