Class: Fog::AWS::RDS::Snapshots

Inherits:
Collection
  • Object
show all
Defined in:
lib/fog/aws/models/rds/snapshots.rb

Instance Method Summary collapse

Constructor Details

#initialize(attributes) ⇒ Snapshots

Returns a new instance of Snapshots.



11
12
13
14
15
16
17
18
19
20
 
# File 'lib/fog/aws/models/rds/snapshots.rb', line 11

def initialize(attributes)
  self.filters ||= {}
  if attributes[:server]
    filters[:identifier] = attributes[:server].id
  end
  if attributes[:type]
    filters[:type] = attributes[:type]
  end
  super
end

Instance Method Details

#all(filters_arg = filters) ⇒ Object

This method does NOT return all snapshots. Its implementation deliberately returns a single page of results for any one call. It will return a single page based on the current or provided filters, updating the filters with the marker for the next page. Calling this repeatedly will iterate through pages. See the implementation of each for an example of such iteration.

It is arguably incorrect for the method not to return all snapshots, particularly considering the implementation in the corresponding ‘elb’ files. But this implementation has been released, and backwards-compatibility requires leaving it as implemented.



30
31
32
33
34
35
36
 
# File 'lib/fog/aws/models/rds/snapshots.rb', line 30

def all(filters_arg = filters)
  filters.merge!(filters_arg)

  page = service.describe_db_snapshots(filters).body['DescribeDBSnapshotsResult']
  filters[:marker] = page['Marker']
  load(page['DBSnapshots'])
end

#each(filters_arg = filters) ⇒ Object

This will execute a block for each snapshot, fetching new pages of snapshots as required.



39
40
41
42
43
44
45
46
47
48
49
 
# File 'lib/fog/aws/models/rds/snapshots.rb', line 39

def each(filters_arg = filters)
  if block_given?
    begin
      page = self.all(filters_arg)
      # We need to explicitly use the base 'each' method here on the page, otherwise we get infinite recursion
      base_each = Fog::Collection.instance_method(:each)
      base_each.bind(page).call { |snapshot| yield snapshot }
    end while self.filters[:marker]
  end
  self
end

#get(identity) ⇒ Object 



51
52
53
54
55
56
 
# File 'lib/fog/aws/models/rds/snapshots.rb', line 51

def get(identity)
  data = service.describe_db_snapshots(:snapshot_id => identity).body['DescribeDBSnapshotsResult']['DBSnapshots'].first
  new(data) # data is an attribute hash
rescue Fog::AWS::RDS::NotFound
  nil
end

#new(attributes = {}) ⇒ Object 



58
59
60
61
62
63
64
 
# File 'lib/fog/aws/models/rds/snapshots.rb', line 58

def new(attributes = {})
  if server
    super({ :instance_id => server.id }.merge!(attributes))
  else
    super
  end
end