Class: Wurk::Limiter::ServerMiddleware

Inherits:

Object

• Object
• Wurk::Limiter::ServerMiddleware

Includes:

Middleware::ServerMiddleware

Defined in:

lib/wurk/limiter/server_middleware.rb

Overview

Catches OverLimit (and any class registered in Limiter.config.errors), bumps job['overrated'], and decides what to do next:

* reschedule disabled (`reschedule: 0`) → re-raise so the normal
retry/dead pipeline handles it (spec §1.2/§1.4 behaviour).
* still under the cap → reschedule onto the same queue at
`Time.now + backoff` via `Client.push`.
* cap reached (`overrated >= reschedule`, default 20) → **poison
brake** (#16): a job that's still rate-limited after N reschedules
is saturating the limiter, so instead of dumping it into another
25× retry loop we route it straight to the dead set tagged
`rate_limited`, bumping `jobs.rate_limited` and firing death
handlers. Bounded: termination at exactly `reschedule` attempts.

Constant Summary

DEAD_REASON =

'rate_limited'

Instance Attribute Summary

• #config ⇒ Object included from Middleware::ServerMiddleware

  Returns the value of attribute config.

Instance Method Summary

• #call(_worker, job, _queue) ⇒ Object
• #logger ⇒ Object included from Middleware::ServerMiddleware
• #redis ⇒ Object included from Middleware::ServerMiddleware
• #redis_pool ⇒ Object included from Middleware::ServerMiddleware

Instance Attribute Details

#config ⇒ Object Originally defined in module Middleware::ServerMiddleware

Returns the value of attribute config.

Instance Method Details

#call(_worker, job, _queue) ⇒ Object

# File 'lib/wurk/limiter/server_middleware.rb', line 23

def call(_worker, job, _queue)
  yield
rescue StandardError => e
  raise unless over_limit?(e)

  handle_over_limit(job, e)
end

#logger ⇒ Object Originally defined in module Middleware::ServerMiddleware

#redis ⇒ Object Originally defined in module Middleware::ServerMiddleware

#redis_pool ⇒ Object Originally defined in module Middleware::ServerMiddleware