Class: Wurk::Fetcher

Inherits:

Object

• Object
• Wurk::Fetcher

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

• #bulk_requeue(in_progress) ⇒ Object
• #retrieve_work ⇒ Object
• #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.

Instance Method Details

#bulk_requeue(in_progress) ⇒ Object

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

def bulk_requeue(in_progress); end

#retrieve_work ⇒ Object

# 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.

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

def terminate; end