Class: Wurk::Fetcher

Inherits:
Object
  • Object
show all
Defined in:
lib/wurk/fetcher.rb,
lib/wurk/fetcher/reaper.rb,
lib/wurk/fetcher/reliable.rb

Overview

Abstract fetcher. Wurk::Fetcher::Reliable is the only implementation we ship and the only one we recommend — BLMOVE-based reliable fetch. No "basic fetch" mode.

Defined Under Namespace

Classes: Reaper, Reliable

Instance Method Summary collapse

Instance Method Details

#bulk_requeue(in_progress) ⇒ Object 



9
 
# File 'lib/wurk/fetcher.rb', line 9

def bulk_requeue(in_progress); end

#flush_pending_acks ⇒ Object

Send any ACK the fetcher is holding back rather than sending immediately. Processor calls this as it stops, so a job that finished but whose ACK never caught a fetch to ride on can't be reclaimed as unfinished. No-op in the abstract base; only Reliable defers.



20
 
# File 'lib/wurk/fetcher.rb', line 20

def flush_pending_acks; end

#retrieve_work ⇒ Object 



8
 
# File 'lib/wurk/fetcher.rb', line 8

def retrieve_work; end

#terminate ⇒ Object

Quiet hook: Manager#quiet calls this so retrieve_work can short-circuit and stop pulling new work the instant a process is quieted. No-op in the abstract base; Reliable flips its drain flag.



14
 
# File 'lib/wurk/fetcher.rb', line 14

def terminate; end