Module: Karafka::Pro::Routing::Features::Multiplexing::SubscriptionGroup

Defined in:
lib/karafka/pro/routing/features/multiplexing/subscription_group.rb

Overview

Adds methods needed for the multiplexing to work

Instance Method Summary collapse

Instance Method Details

#multiplexing ⇒ Config

Returns multiplexing config.

Returns:

  • (Config) —

    multiplexing config



14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/karafka/pro/routing/features/multiplexing/subscription_group.rb', line 14

def multiplexing
  @multiplexing ||= begin
    max = @details.fetch(:multiplexing_max, 1)
    min = @details.fetch(:multiplexing_min, max)
    boot = @details.fetch(:multiplexing_boot, max / 2)
    scale_delay = @details.fetch(:multiplexing_scale_delay, 60_000)
    active = max > 1

    Config.new(
      active: active,
      min: min,
      max: max,
      boot: boot,
      scale_delay: scale_delay
    )
  end
end

#multiplexing? ⇒ Boolean

Returns is multiplexing active.

Returns:

  • (Boolean) —

    is multiplexing active



33
34
35
 
# File 'lib/karafka/pro/routing/features/multiplexing/subscription_group.rb', line 33

def multiplexing?
  multiplexing.active?
end