Class: Dynamoid::AdapterPlugin::AwsSdkV3::UntilPastTableStatus

Inherits:
Object
  • Object
show all
Defined in:
lib/dynamoid/adapter_plugin/aws_sdk_v3/until_past_table_status.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(client, table_name, status = :creating) ⇒ UntilPastTableStatus

Returns a new instance of UntilPastTableStatus.

[View source] [View on GitHub]

10
11
12
13
14
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/until_past_table_status.rb', line 10

def initialize(client, table_name, status = :creating)
  @client = client
  @table_name = table_name
  @status = status
end

Instance Attribute Details

#client ⇒ Object (readonly)

Returns the value of attribute client.

[View on GitHub]

8
9
10
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/until_past_table_status.rb', line 8

def client
  @client
end

#status ⇒ Object (readonly)

Returns the value of attribute status.

[View on GitHub]

8
9
10
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/until_past_table_status.rb', line 8

def status
  @status
end

#table_name ⇒ Object (readonly)

Returns the value of attribute table_name.

[View on GitHub]

8
9
10
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/until_past_table_status.rb', line 8

def table_name
  @table_name
end

Instance Method Details

#call ⇒ Object

[View source] [View on GitHub]

16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/until_past_table_status.rb', line 16

def call
  counter = 0
  resp = nil
  begin
    check = { again: true }
    while check[:again]
      sleep Dynamoid::Config.sync_retry_wait_seconds
      resp = client.describe_table(table_name: table_name)
      check = check_table_status?(counter, resp, status)
      Dynamoid.logger.info "Checked table status for #{table_name} (check #{check.inspect})"
      counter += 1
    end
  # If you issue a DescribeTable request immediately after a CreateTable
  #   request, DynamoDB might return a ResourceNotFoundException.
  # This is because DescribeTable uses an eventually consistent query,
  #   and the metadata for your table might not be available at that moment.
  # Wait for a few seconds, and then try the DescribeTable request again.
  # See: http://docs.aws.amazon.com/sdkforruby/api/Aws/DynamoDB/Client.html#describe_table-instance_method
  rescue Aws::DynamoDB::Errors::ResourceNotFoundException => e
    case status
    when :creating
      if counter >= Dynamoid::Config.sync_retry_max_times
        Dynamoid.logger.warn "Waiting on table metadata for #{table_name} (check #{counter})"
        retry # start over at first line of begin, does not reset counter
      else
        Dynamoid.logger.error "Exhausted max retries (Dynamoid::Config.sync_retry_max_times) waiting on table metadata for #{table_name} (check #{counter})"
        raise e
      end
    else
      # When deleting a table, "not found" is the goal.
      Dynamoid.logger.info "Checked table status for #{table_name}: Not Found (check #{check.inspect})"
    end
  end
end