Contents

# frozen_string_literal: true

module DatadogBackup
  # SLO specific overrides for backup and restore.
  class SLOs < Resources
    def all
      get_all
    end

    def backup
      LOGGER.info("Starting diffs on #{::DatadogBackup::ThreadPool::TPOOL.max_length} threads")
      futures = all.map do |slo|
        Concurrent::Promises.future_on(::DatadogBackup::ThreadPool::TPOOL, slo) do |board|
          id = board[id_keyname]
          get_and_write_file(id)
        end
      end

      watcher = ::DatadogBackup::ThreadPool.watcher
      watcher.join if watcher.status

      Concurrent::Promises.zip(*futures).value!
    end

    def get_by_id(id)
      begin
        slo = except(get(id))
      rescue Faraday::ResourceNotFound => e
        slo = {}
      end
      except(slo)
    end

    def initialize(options)
      super(options)
      @banlist = %w[modified_at url].freeze
    end

    # Return the Faraday body from a response with a 2xx status code, otherwise raise an error
    def body_with_2xx(response)
      unless response.status.to_s =~ /^2/
        raise "#{caller_locations(1,
                                  1)[0].label} failed with error #{response.status}"
      end

      response.body.fetch('data')
    end

    private

    def api_version
      'v1'
    end

    def api_resource_name
      'slo'
    end

    def id_keyname
      'id'
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
datadog_backup-4.0.1	lib/datadog_backup/slos.rb
datadog_backup-4.0.0	lib/datadog_backup/slos.rb
datadog_backup-3.3.0	lib/datadog_backup/slos.rb