module Octo::Scheduler
Public Instance Methods
schedule_baseline()
click to toggle source
Schedules the processing of baselines
# File lib/octocore-cassandra/scheduler.rb, line 36 def schedule_baseline baseline_classes = [ Octo::ProductBaseline, Octo::CategoryBaseline, Octo::TagBaseline ] baseline_classes.each do |clazz| clazz.send(:get_typecounters).each do |counter| name = [clazz, counter].join('::') config = { class: clazz.to_s, args: [counter], cron: '* * * * *', persists: true, queue: 'baseline_processing' } Resque.set_schedule name, config end end end
schedule_counters()
click to toggle source
Setup
the schedules for counters.
# File lib/octocore-cassandra/scheduler.rb, line 13 def schedule_counters counter_classes = [ Octo::ProductHit, Octo::CategoryHit, Octo::TagHit, Octo::ApiHit, Octo::NewsfeedHit ] counter_classes.each do |clazz| clazz.send(:get_typecounters).each do |counter| name = [clazz, counter].join('::') config = { class: clazz.to_s, args: [counter], cron: '* * * * *', persist: true, queue: 'high' } Resque.set_schedule name, config end end # Schedules the processing of baselines def schedule_baseline baseline_classes = [ Octo::ProductBaseline, Octo::CategoryBaseline, Octo::TagBaseline ] baseline_classes.each do |clazz| clazz.send(:get_typecounters).each do |counter| name = [clazz, counter].join('::') config = { class: clazz.to_s, args: [counter], cron: '* * * * *', persists: true, queue: 'baseline_processing' } Resque.set_schedule name, config end end end # Schedules the daily mail, to be sent at noon def schedule_subscribermail name = 'SubscriberDailyMailer' config = { class: Octo::Mailer::SubscriberMailer, args: [], cron: '0 0 * * *', persist: true, queue: 'subscriber_notifier' } Resque.set_schedule name, config end end
schedule_subscribermail()
click to toggle source
Schedules the daily mail, to be sent at noon
# File lib/octocore-cassandra/scheduler.rb, line 58 def schedule_subscribermail name = 'SubscriberDailyMailer' config = { class: Octo::Mailer::SubscriberMailer, args: [], cron: '0 0 * * *', persist: true, queue: 'subscriber_notifier' } Resque.set_schedule name, config end