summaryrefslogtreecommitdiff
path: root/app/workers/self_monitoring_project_create_worker.rb
diff options
context:
space:
mode:
authorGitLab Bot <gitlab-bot@gitlab.com>2020-01-07 12:07:55 +0000
committerGitLab Bot <gitlab-bot@gitlab.com>2020-01-07 12:07:55 +0000
commit05f1d5d9813332bdd456cb358517e56168a24224 (patch)
treef9ed7a2692a537b5e1e541318f39d7464fdd8098 /app/workers/self_monitoring_project_create_worker.rb
parente440c86979e9c02a09fb6558f59a1fbe29433b51 (diff)
downloadgitlab-ce-05f1d5d9813332bdd456cb358517e56168a24224.tar.gz
Add latest changes from gitlab-org/gitlab@master
Diffstat (limited to 'app/workers/self_monitoring_project_create_worker.rb')
-rw-r--r--app/workers/self_monitoring_project_create_worker.rb40
1 files changed, 40 insertions, 0 deletions
diff --git a/app/workers/self_monitoring_project_create_worker.rb b/app/workers/self_monitoring_project_create_worker.rb
new file mode 100644
index 00000000000..69bc5431ff7
--- /dev/null
+++ b/app/workers/self_monitoring_project_create_worker.rb
@@ -0,0 +1,40 @@
+# frozen_string_literal: true
+
+class SelfMonitoringProjectCreateWorker
+ include ApplicationWorker
+ include ExclusiveLeaseGuard
+
+ # This worker falls under Self-monitoring with Monitor::APM group. However,
+ # self-monitoring is not classified as a feature category but rather as
+ # Other Functionality. Metrics seems to be the closest feature_category for
+ # this worker.
+ feature_category :metrics
+
+ LEASE_TIMEOUT = 15.minutes.to_i
+
+ EXCLUSIVE_LEASE_KEY = 'self_monitoring_service_creation_deletion'
+
+ def perform
+ try_obtain_lease do
+ Gitlab::DatabaseImporters::SelfMonitoring::Project::CreateService.new.execute
+ end
+ end
+
+ # @param job_id [String]
+ # Job ID that is used to construct the cache keys.
+ # @return [Hash]
+ # Returns true if the job is enqueued or in progress and false otherwise.
+ def self.in_progress?(job_id)
+ Gitlab::SidekiqStatus.job_status(Array.wrap(job_id)).first
+ end
+
+ private
+
+ def lease_key
+ EXCLUSIVE_LEASE_KEY
+ end
+
+ def lease_timeout
+ LEASE_TIMEOUT
+ end
+end