Module: Gitlab::EventStore::Subscriber

Extended by:
ActiveSupport::Concern
Included in:
Ci::InitializePipelinesIidSequenceWorker, MergeRequests::CreateApprovalEventWorker, MergeRequests::CreateApprovalNoteWorker, MergeRequests::ExecuteApprovalHooksWorker, MergeRequests::ResolveTodosAfterApprovalWorker, MergeRequests::SetReviewerReviewedWorker, MergeRequests::UpdateHeadPipelineWorker, Ml::ExperimentTracking::AssociateMlCandidateToPackageWorker, Namespaces::UpdateRootStatisticsWorker
Defined in:
lib/gitlab/event_store/subscriber.rb

Instance Method Summary collapse

Instance Method Details

#handle_event(event) ⇒ Object

Raises:

  • (NotImplementedError) 


39
40
41
 
# File 'lib/gitlab/event_store/subscriber.rb', line 39

def handle_event(event)
  raise NotImplementedError, 'you must implement this methods in order to handle events'
end

#perform(event_type, data) ⇒ Object

Raises:



29
30
31
32
33
34
35
36
37
 
# File 'lib/gitlab/event_store/subscriber.rb', line 29

def perform(event_type, data)
  raise InvalidEvent, event_type unless self.class.const_defined?(event_type)

  event = event_type.constantize.new(
    data: data.with_indifferent_access
  )

  handle_event(event)
end