Module: Wurk::API::Fast::QueueExt

Included in:
Queue
Defined in:
lib/wurk/api/fast.rb

Overview

Extension to Wurk::Queue. Pure server-side delete by jid / class — no network round-trips per match.

Instance Method Summary collapse

Instance Method Details

#delete_by_class(klass) ⇒ Integer

Returns payloads removed.

Parameters:

  • klass (Class, String, Symbol)

Returns:

  • (Integer) —

    payloads removed.

Raises:

  • (ArgumentError) 


28
29
30
31
32
33
 
# File 'lib/wurk/api/fast.rb', line 28

def delete_by_class(klass)
  klass_name = klass.is_a?(Class) ? klass.name : klass.to_s
  raise ArgumentError, 'class name required' if klass_name.empty?

  Wurk.redis { |conn| Wurk::Lua::FastDelete.delete_by_class(conn, Keys.queue(name), klass_name) }
end

#delete_job(jid) ⇒ String?

Returns the deleted job's JSON, or nil when no job in the queue has that jid — Pro's contract, so if q.delete_job(jid) branches on whether anything was removed.

Returns:

  • (String, nil) —

    the deleted job's JSON, or nil when no job in the queue has that jid — Pro's contract, so if q.delete_job(jid) branches on whether anything was removed.

Raises:

  • (ArgumentError) 


20
21
22
23
24
 
# File 'lib/wurk/api/fast.rb', line 20

def delete_job(jid)
  raise ArgumentError, 'jid required' if jid.nil? || jid.to_s.empty?

  Wurk.redis { |conn| Wurk::Lua::FastDelete.delete_job(conn, Keys.queue(name), jid.to_s) }
end