Module: EventEngine::ProcessType

Defined in:
lib/event_engine/process_type.rb

Constant Summary collapse

ALL = 
%i[inline background durable broker telemetry sourced].freeze
PROCESSORS = 
{
  inline: :subscribers,
  background: :subscribers,
  durable: :delivery,
  broker: :delivery,
  telemetry: :telemetry,
  sourced: :sourcing
}.freeze

Class Method Summary collapse

Class Method Details

.all ⇒ Object 



14
15
16
 
# File 'lib/event_engine/process_type.rb', line 14

def self.all
  ALL
end

.known?(type) ⇒ Boolean

Returns:

  • (Boolean) 


22
23
24
 
# File 'lib/event_engine/process_type.rb', line 22

def self.known?(type)
  ALL.include?(type)
end

.processor_for(type) ⇒ Object 



18
19
20
 
# File 'lib/event_engine/process_type.rb', line 18

def self.processor_for(type)
  PROCESSORS[type]
end