summaryrefslogtreecommitdiff
path: root/lib/container_registry/migration.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/container_registry/migration.rb')
-rw-r--r--lib/container_registry/migration.rb14
1 files changed, 14 insertions, 0 deletions
diff --git a/lib/container_registry/migration.rb b/lib/container_registry/migration.rb
index 005ef880034..8377190c83c 100644
--- a/lib/container_registry/migration.rb
+++ b/lib/container_registry/migration.rb
@@ -20,6 +20,8 @@ module ContainerRegistry
delegate :container_registry_import_max_step_duration, to: ::Gitlab::CurrentSettings
delegate :container_registry_import_target_plan, to: ::Gitlab::CurrentSettings
delegate :container_registry_import_created_before, to: ::Gitlab::CurrentSettings
+ delegate :container_registry_pre_import_timeout, to: ::Gitlab::CurrentSettings
+ delegate :container_registry_import_timeout, to: ::Gitlab::CurrentSettings
alias_method :max_tags_count, :container_registry_import_max_tags_count
alias_method :max_retries, :container_registry_import_max_retries
@@ -27,6 +29,8 @@ module ContainerRegistry
alias_method :max_step_duration, :container_registry_import_max_step_duration
alias_method :target_plan_name, :container_registry_import_target_plan
alias_method :created_before, :container_registry_import_created_before
+ alias_method :pre_import_timeout, :container_registry_pre_import_timeout
+ alias_method :import_timeout, :container_registry_import_timeout
end
def self.enabled?
@@ -52,6 +56,8 @@ module ContainerRegistry
#
return 25 if Feature.enabled?(:container_registry_migration_phase2_capacity_25)
return 10 if Feature.enabled?(:container_registry_migration_phase2_capacity_10)
+ return 5 if Feature.enabled?(:container_registry_migration_phase2_capacity_5)
+ return 2 if Feature.enabled?(:container_registry_migration_phase2_capacity_2)
return 1 if Feature.enabled?(:container_registry_migration_phase2_capacity_1)
0
@@ -64,5 +70,13 @@ module ContainerRegistry
def self.all_plans?
Feature.enabled?(:container_registry_migration_phase2_all_plans)
end
+
+ def self.enqueue_twice?
+ Feature.enabled?(:container_registry_migration_phase2_enqueue_twice)
+ end
+
+ def self.enqueuer_loop?
+ Feature.enabled?(:container_registry_migration_phase2_enqueuer_loop)
+ end
end
end