Class: Dynamoid::AdapterPlugin::AwsSdkV3::Scan

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(client, table, conditions = {}, options = {}) ⇒ Scan

Returns a new instance of Scan.



13
14
15
16
17
18
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/scan.rb', line 13

def initialize(client, table, conditions = {}, options = {})
  @client = client
  @table = table
  @conditions = conditions
  @options = options
end

Instance Attribute Details

#client ⇒ Object (readonly)

Returns the value of attribute client.



11
12
13
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/scan.rb', line 11

def client
  @client
end

#conditions ⇒ Object (readonly)

Returns the value of attribute conditions.



11
12
13
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/scan.rb', line 11

def conditions
  @conditions
end

#options ⇒ Object (readonly)

Returns the value of attribute options.



11
12
13
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/scan.rb', line 11

def options
  @options
end

#table ⇒ Object (readonly)

Returns the value of attribute table.



11
12
13
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/scan.rb', line 11

def table
  @table
end

Instance Method Details

#call ⇒ Object 



20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
 
# File 'lib/dynamoid/adapter_plugin/aws_sdk_v3/scan.rb', line 20

def call
  request = build_request

  Enumerator.new do |yielder|
    api_call = -> (request) do
      client.scan(request).tap do |response|
        yielder << response
      end
    end

    middlewares = Middleware::Backoff.new(
      Middleware::StartKey.new(
        Middleware::Limit.new(api_call, record_limit: record_limit, scan_limit: scan_limit)
      )
    )

    catch :stop_pagination do
      loop do
        middlewares.call(request)
      end
    end
  end
end