Module: Pigeon::API::CoreAPI

Included in:
Pigeon
Defined in:
lib/pigeon/api.rb

Overview

Delegate methods to Core module

Instance Method Summary collapse

Instance Method Details

#config ⇒ Object 



12
13
14
 
# File 'lib/pigeon/api.rb', line 12

def config
  Core.config
end

#configure ⇒ Object 



8
9
10
 
# File 'lib/pigeon/api.rb', line 8

def configure(&)
  Core.configure(&)
end

#initialize_karafka ⇒ Object 



16
17
18
 
# File 'lib/pigeon/api.rb', line 16

def initialize_karafka
  Core.initialize_karafka
end

#karafka_producer ⇒ Object 



20
21
22
 
# File 'lib/pigeon/api.rb', line 20

def karafka_producer
  Core.karafka_producer
end

#processing? ⇒ Boolean

Returns:



40
41
42
 
# File 'lib/pigeon/api.rb', line 40

def processing?
  Core.processing?
end

#processor(auto_start: false) ⇒ Object 



28
29
30
 
# File 'lib/pigeon/api.rb', line 28

def processor(auto_start: false)
  Core.processor(auto_start: auto_start)
end

#publisher ⇒ Object 



24
25
26
 
# File 'lib/pigeon/api.rb', line 24

def publisher
  Core.publisher
end

#start_processing(batch_size: 100, interval: 5, thread_count: 2) ⇒ Object 



32
33
34
 
# File 'lib/pigeon/api.rb', line 32

def start_processing(batch_size: 100, interval: 5, thread_count: 2)
  Core.start_processing(batch_size: batch_size, interval: interval, thread_count: thread_count)
end

#stop_processing ⇒ Object 



36
37
38
 
# File 'lib/pigeon/api.rb', line 36

def stop_processing
  Core.stop_processing
end