Module: SidekiqScheduler::Worker::ClassMethods

Defined in:
lib/sidekiq-scheduler/worker.rb,
lib/sidekiq-scheduler/testing.rb

Instance Method Summary collapse

Instance Method Details

#perform_at(timestamp, *args) ⇒ Object 



7
8
9
 
# File 'lib/sidekiq-scheduler/worker.rb', line 7

def perform_at(timestamp, *args)
  Sidekiq::Client.delayed_push(timestamp, 'class' => self.name, 'args' => args)
end

#perform_at_old ⇒ Object 



6
7
8
 
# File 'lib/sidekiq-scheduler/testing.rb', line 6

def perform_at(timestamp, *args)
  Sidekiq::Client.delayed_push(timestamp, 'class' => self.name, 'args' => args)
end

#perform_in(seconds_from_now, *args) ⇒ Object 



11
12
13
 
# File 'lib/sidekiq-scheduler/worker.rb', line 11

def perform_in(seconds_from_now, *args)
  Sidekiq::Client.delayed_push(Time.now + seconds_from_now, 'class' => self.name, 'args' => args)
end

#perform_in_old ⇒ Object 



12
13
14
 
# File 'lib/sidekiq-scheduler/testing.rb', line 12

def perform_in(seconds_from_now, *args)
  Sidekiq::Client.delayed_push(Time.now + seconds_from_now, 'class' => self.name, 'args' => args)
end

#remove_delayed(*args) ⇒ Object 



15
16
17
 
# File 'lib/sidekiq-scheduler/worker.rb', line 15

def remove_delayed(*args)
  Sidekiq::Client.remove_all_delayed(self.name, *args)
end

#remove_delayed_from_timestamp(timestamp, *args) ⇒ Object 



19
20
21
 
# File 'lib/sidekiq-scheduler/worker.rb', line 19

def remove_delayed_from_timestamp(timestamp, *args)
  Sidekiq::Client.remove_delayed(timestamp, self.name, *args)
end

#remove_delayed_from_timestamp_old ⇒ Object 



25
26
27
 
# File 'lib/sidekiq-scheduler/testing.rb', line 25

def remove_delayed_from_timestamp(timestamp, *args)
  Sidekiq::Client.remove_delayed(timestamp, self.name, *args)
end

#remove_delayed_old ⇒ Object 



18
19
20
 
# File 'lib/sidekiq-scheduler/testing.rb', line 18

def remove_delayed(*args)
  Sidekiq::Client.remove_all_delayed(self.name, *args)
end