Contents

class Jets::CLI::Maintenance::Worker
  class Restorer < Base
    def restore_concurrency_settings
      data = read_from_s3
      data.each do |function_name, settings|
        lambda_function = Jets::CLI::Lambda::Function.new(function_name)
        lambda_function.reserved_concurrency = settings["reserved_concurrency"] if settings["reserved_concurrency"]
        lambda_function.provisioned_concurrency = settings["provisioned_concurrency"] if settings["provisioned_concurrency"]
      end
    end

    private

    def read_from_s3
      response = s3.get_object(bucket: s3_bucket, key: state_file)
      JSON.parse(response.body.read)
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
jets-6.0.5	lib/jets/cli/maintenance/worker/restorer.rb
jets-6.0.4	lib/jets/cli/maintenance/worker/restorer.rb
jets-6.0.3	lib/jets/cli/maintenance/worker/restorer.rb
jets-6.0.2	lib/jets/cli/maintenance/worker/restorer.rb