Class: SpeedLimiter::Throttle

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/speed_limiter/throttle.rb

Overview

with actual throttle limits

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(key, config:, **params) ⇒ Throttle

Returns a new instance of Throttle.

Parameters:

  • key (String, #to_s) —

    Throttle key name

  • params (Hash) —

    a customizable set of options

Options Hash (**params):

  • :limit (Integer) —

    limit count per period

  • :period (Integer) —

    period time (seconds)

  • :on_throttled (Proc, #call) —

    Block called when limit exceeded, with ttl(Float) and key as argument

  • :retry (true, Hash) —

    Retry options. (see Retryable.retryable for details)



17
18
19
20
21
22
 
# File 'lib/speed_limiter/throttle.rb', line 17

def initialize(key, config:, **params)
  params[:key] = key.to_s

  @config = config
  @params = ThrottleParams.new(config: config, **params)
end

Instance Attribute Details

#block ⇒ Object (readonly)

Returns the value of attribute block.



23
24
25
 
# File 'lib/speed_limiter/throttle.rb', line 23

def block
  @block
end

#config ⇒ Object (readonly)

Returns the value of attribute config.



23
24
25
 
# File 'lib/speed_limiter/throttle.rb', line 23

def config
  @config
end

#params ⇒ Object (readonly)

Returns the value of attribute params.



23
24
25
 
# File 'lib/speed_limiter/throttle.rb', line 23

def params
  @params
end

Instance Method Details

#call {|state| ... } ⇒ any

Returns block return value.

Yields:

  • (state)

Yield Parameters:

Returns:

  • (any) —

    block return value



30
31
32
33
34
35
36
 
# File 'lib/speed_limiter/throttle.rb', line 30

def call(&block)
  if use_retryable?
    Retryable.retryable(**retryable_options) { run_block(&block) }
  else
    run_block(&block)
  end
end