Class: Wurk::Limiter::Window

Inherits:
Base
  • Object
show all
Defined in:
lib/wurk/limiter/window.rb

Overview

Sliding window via ZSET of timestamps. Accepts symbolic units or a raw Integer (in seconds). Used-units expand to N ZADDs in the Lua script so multi-charge calls remain atomic.

Constant Summary collapse

WAIT_SLEEP = 
0.5

Instance Attribute Summary

Attributes inherited from Base

#name, #options

Instance Method Summary collapse

Methods inherited from Base

#delete, #fingerprint, #reset

Constructor Details

#initialize(name, **options) ⇒ Window

Returns a new instance of Window.



15
16
17
18
19
 
# File 'lib/wurk/limiter/window.rb', line 15

def initialize(name, **options)
  # Symbol or raw Integer (spec ยง1.2: window accepts both).
  Limiter.interval_seconds(options[:interval], allow_integer: true)
  super
end

Instance Method Details

#size ⇒ Object 



21
22
23
 
# File 'lib/wurk/limiter/window.rb', line 21

def size
  window_state.first
end

#status ⇒ Object

used = entries still inside the window; limit = count; reset_at = when the oldest entry slides out (freeing a slot), or nil when idle (#16).



28
29
30
31
 
# File 'lib/wurk/limiter/window.rb', line 28

def status
  used, oldest = window_state
  build_status(used: used, limit: @options[:count], reset_at: oldest && (oldest + interval_seconds))
end

#type ⇒ Object 



13
 
# File 'lib/wurk/limiter/window.rb', line 13

def type = :window

#within_limit(used: 1, &block) ⇒ Object

Raises:

  • (ArgumentError) 


33
34
35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/wurk/limiter/window.rb', line 33

def within_limit(used: 1, &block)
  raise ArgumentError, 'block required' unless block

  deadline = ::Time.now.to_f + @options[:wait_timeout]
  loop do
    ok, _current, _oldest = acquire(used)
    return block.call if ok.to_i == 1

    remaining = deadline - ::Time.now.to_f
    raise OverLimit, self if remaining <= 0

    sleep [remaining, WAIT_SLEEP].min
  end
end