gitlab-org--gitlab-foss/app/workers/reactive_caching_worker.rb

# frozen_string_literal: true

class ReactiveCachingWorker
  include ApplicationWorker

  def perform(class_name, id, *args)
    klass = begin
      class_name.constantize
    rescue NameError
      nil
    end
    return unless klass

    klass
      .reactive_cache_worker_finder
      .call(id, *args)
      .try(:exclusively_update_reactive_cache!, *args)
  end
end
Enable frozen string literals for app/workers/*.rb 2018-06-27 03:23:28 -04:00			`# frozen_string_literal: true`

Add a ReactiveCaching concern for use in the KubernetesService 2016-12-16 23:09:50 -05:00			`class ReactiveCachingWorker`
Add ApplicationWorker and make every worker include it 2017-11-28 11:08:30 -05:00			`include ApplicationWorker`
Add a ReactiveCaching concern for use in the KubernetesService 2016-12-16 23:09:50 -05:00
Merge branch '24185-legacy-ci-status-reactive-cache' into 'security' Use ReactiveCaching to update external CI status asynchronously See https://dev.gitlab.org/gitlab/gitlabhq/merge_requests/2055 2017-01-12 17:31:02 -05:00			`def perform(class_name, id, *args)`
Add a ReactiveCaching concern for use in the KubernetesService 2016-12-16 23:09:50 -05:00			`klass = begin`
Update Metrics references to Object path On reload, references to Metrics within classes in the Gitlab::Metrics module fail. Update all references to ::Gitlab::Metrics so that constant lookup finds the right module in development. This fix should not impact production. 2019-02-14 13:05:35 -05:00			`class_name.constantize`
Add a ReactiveCaching concern for use in the KubernetesService 2016-12-16 23:09:50 -05:00			`rescue NameError`
			`nil`
			`end`
			`return unless klass`

Allow reactive caching to be used in services Add support for defining a reactive_cache_worker_finder function that will be used by the reactive_caching_worker to generate/initialize the calling object. This allows reactive caching to work with Services where the object cannot be obtained from DB but a new object can be initialized. 2019-04-04 13:27:29 -04:00			`klass`
			`.reactive_cache_worker_finder`
			`.call(id, *args)`
			`.try(:exclusively_update_reactive_cache!, *args)`
Add a ReactiveCaching concern for use in the KubernetesService 2016-12-16 23:09:50 -05:00			`end`
			`end`