Sha256: cfe32cf4328326b35d35f3210799970d006de9cf747c3378ce4a9dcf111a3a14

Contents?: true

Size: 1.4 KB

Versions: 6

Compression:

Stored size: 1.4 KB

Contents

require 'fog/core/collection'
require 'fog/aws/models/rds/log_file'

module Fog
  module AWS
    class RDS
      class LogFiles < Fog::Collection
        attribute :filters
        attribute :rds_id
        model Fog::AWS::RDS::LogFile

        def initialize(attributes)
          self.filters ||= {}
          super
        end

        # This method deliberately returns only a single page of results
        def all(filters_arg = filters)
          filters.merge!(filters_arg)

          result = service.describe_db_log_files(rds_id, filters).body['DescribeDBLogFilesResult']
          filters[:marker] = result['Marker']
          load(result['DBLogFiles'])
        end

        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 { |log_file| yield log_file }
            end while self.filters[:marker]
          end
          self
        end

        def get(file_name=nil)
          if file_name
            matches = self.select {|log_file| log_file.name.upcase == file_name.upcase}
            return matches.first unless matches.empty?
          end
        rescue Fog::AWS::RDS::NotFound
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

Version Path
fog-aws-0.1.1 lib/fog/aws/models/rds/log_files.rb
fog-aws-0.1.0 lib/fog/aws/models/rds/log_files.rb
fog-aws-0.0.8 lib/fog/aws/models/rds/log_files.rb
fog-aws-0.0.7 lib/fog/aws/models/rds/log_files.rb
fog-aws-0.0.6 lib/fog/aws/models/rds/log_files.rb
fog-aws-0.0.5 lib/fog/aws/models/rds/log_files.rb