Class: Karafka::Pro::Routing::Features::ParallelSegments::Config

Inherits:
Struct
  • Object
show all
Defined in:
lib/karafka/pro/routing/features/parallel_segments/config.rb

Overview

Note:

Used on the consumer level, not per topic

Config for parallel segments.

Instance Attribute Summary collapse

Instance Attribute Details

#active ⇒ Object Also known as: active?

Returns the value of attribute active

Returns:

  • (Object) —

    the current value of active



13
14
15
 
# File 'lib/karafka/pro/routing/features/parallel_segments/config.rb', line 13

def active
  @active
end

#count ⇒ Object

Returns the value of attribute count

Returns:

  • (Object) —

    the current value of count



13
14
15
 
# File 'lib/karafka/pro/routing/features/parallel_segments/config.rb', line 13

def count
  @count
end

#merge_key ⇒ Object

Returns the value of attribute merge_key

Returns:

  • (Object) —

    the current value of merge_key



13
14
15
 
# File 'lib/karafka/pro/routing/features/parallel_segments/config.rb', line 13

def merge_key
  @merge_key
end

#partitioner ⇒ Object

Returns the value of attribute partitioner

Returns:

  • (Object) —

    the current value of partitioner



13
14
15
 
# File 'lib/karafka/pro/routing/features/parallel_segments/config.rb', line 13

def partitioner
  @partitioner
end

#reducer ⇒ Object

Returns the value of attribute reducer

Returns:

  • (Object) —

    the current value of reducer



13
14
15
 
# File 'lib/karafka/pro/routing/features/parallel_segments/config.rb', line 13

def reducer
  @reducer
end