Class: Aws::Waiters::Waiter

Inherits:
Object
  • Object
show all
Defined in:
lib/aws-sdk-core/waiters/waiter.rb

Constant Summary collapse

RAISE_HANDLER =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future. 

Seahorse::Client::Plugins::RaiseResponseErrors::Handler

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(options = {}) ⇒ Waiter

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns a new instance of Waiter.



9
10
11
12
13
14
15
 
# File 'lib/aws-sdk-core/waiters/waiter.rb', line 9

def initialize(options = {})
  @poller = options[:poller]
  @max_attempts = options[:max_attempts]
  @delay = options[:delay]
  @before_attempt = Array(options[:before_attempt])
  @before_wait = Array(options[:before_wait])
end

Instance Attribute Details

#delay ⇒ Float Also known as: interval

Returns:

  • (Float) 


24
25
26
 
# File 'lib/aws-sdk-core/waiters/waiter.rb', line 24

def delay
  @delay
end

#max_attempts ⇒ Integer

Returns:

  • (Integer) 


21
22
23
 
# File 'lib/aws-sdk-core/waiters/waiter.rb', line 21

def max_attempts
  @max_attempts
end

#poller ⇒ Object (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



18
19
20
 
# File 'lib/aws-sdk-core/waiters/waiter.rb', line 18

def poller
  @poller
end

Instance Method Details

#before_attempt {|attempts| ... } ⇒ Object

Register a callback that is invoked before every polling attempt. Yields the number of attempts made so far.

waiter.before_attempt do |attempts|
  puts "#{attempts} made, about to make attempt #{attempts + 1}"
end

Throwing ‘:success` or `:failure` from the given block will stop the waiter and return or raise. You can pass a custom message to the throw:

# raises Aws::Waiters::Errors::WaiterFailed
waiter.before_attempt do |attempts|
  throw :failure, 'custom-error-message'
end

# cause the waiter to stop polling and return
waiter.before_attempt do |attempts|
  throw :success
end

Yield Parameters:

  • attempts (Integer) —

    The number of attempts made.



51
52
53
 
# File 'lib/aws-sdk-core/waiters/waiter.rb', line 51

def before_attempt(&block)
  @before_attempt << Proc.new
end

#before_wait {|attempts, response| ... } ⇒ Object

Register a callback that is invoked after an attempt but before sleeping. Yields the number of attempts made and the previous response.

waiter.before_wait do |attempts, response|
  puts "#{attempts} made"
  puts response.error.inspect
  puts response.data.inspect
end

Throwing ‘:success` or `:failure` from the given block will stop the waiter and return or raise. You can pass a custom message to the throw:

# raises Aws::Waiters::Errors::WaiterFailed
waiter.before_attempt do |attempts|
  throw :failure, 'custom-error-message'
end

# cause the waiter to stop polling and return
waiter.before_attempt do |attempts|
  throw :success
end

Yield Parameters:

  • attempts (Integer) —

    The number of attempts already made.

  • response (Seahorse::Client::Response) —

    The response from the previous polling attempts.



82
83
84
 
# File 'lib/aws-sdk-core/waiters/waiter.rb', line 82

def before_wait(&block)
  @before_wait << Proc.new
end

#wait(options) ⇒ Object

Parameters:

  • options (Hash) —

    a customizable set of options

Options Hash (options):

  • :client (Client)
  • :params (Hash) 


88
89
90
91
92
93
94
95
 
# File 'lib/aws-sdk-core/waiters/waiter.rb', line 88

def wait(options)
  catch(:success) do
    failure_msg = catch(:failure) do
      return poll(options)
    end
    raise Errors::WaiterFailed.new(failure_msg || 'waiter failed')
  end || true
end