Module: Karafka::Pro::Routing::Features::Delaying::Topic

Defined in:
lib/karafka/pro/routing/features/delaying/topic.rb

Overview

Topic delaying API extensions

Instance Method Summary collapse

Instance Method Details

#delay_by(*args) ⇒ Object

Just an alias for nice API

Parameters:

  • args (Array) —

    Anything #delaying accepts



31
32
33
 
# File 'lib/karafka/pro/routing/features/delaying/topic.rb', line 31

def delay_by(*args)
  delaying(*args)
end

#delaying(delay = nil) ⇒ Object

Parameters:

  • delay (Integer, nil) (defaults to: nil) —

    minimum age of a message we want to process



14
15
16
17
18
19
20
21
22
23
24
25
26
 
# File 'lib/karafka/pro/routing/features/delaying/topic.rb', line 14

def delaying(delay = nil)
  # Those settings are used for validation
  @delaying ||= begin
    config = Config.new(active: !delay.nil?, delay: delay)

    if config.active?
      factory = ->(*) { Pro::Processing::Filters::Delayer.new(delay) }
      filter(factory)
    end

    config
  end
end

#delaying? ⇒ Boolean

Returns is a given job delaying.

Returns:

  • (Boolean) —

    is a given job delaying



36
37
38
 
# File 'lib/karafka/pro/routing/features/delaying/topic.rb', line 36

def delaying?
  delaying.active?
end

#to_h ⇒ Hash

Returns topic with all its native configuration options plus delaying.

Returns:

  • (Hash) —

    topic with all its native configuration options plus delaying



41
42
43
44
45
 
# File 'lib/karafka/pro/routing/features/delaying/topic.rb', line 41

def to_h
  super.merge(
    delaying: delaying.to_h
  ).freeze
end