Module: Wurk::Fetcher::AtMaxmemory

Included in:
Reliable
Defined in:
lib/wurk/fetcher/at_maxmemory.rb

Overview

Reliable's fetch once Redis has refused one with OOM: a full Redis refuses LMOVE, which would stop every worker draining the queues that filled it. See OomDrain for what makes this possible. Only reached after an OutOfMemoryError, so it costs a healthy fetch nothing.

Constant Summary collapse

REPORT_INTERVAL =

Seconds between error reports while draining a full Redis. Every thread lands here on every fetch for as long as it lasts.

60