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
 
# 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)
    active = max > 1

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

#multiplexing? ⇒ Boolean

Returns is multiplexing active.

Returns:

  • (Boolean) —

    is multiplexing active



26
27
28
 
# File 'lib/karafka/pro/routing/features/multiplexing/subscription_group.rb', line 26

def multiplexing?
  multiplexing.active?
end