Class: Karafka::Routing::Topics

Inherits:

Object

• Object
• Karafka::Routing::Topics

Extended by:

Forwardable

Includes:

Enumerable

Defined in:

lib/karafka/routing/topics.rb

Overview

Abstraction layer on top of groups of topics

Direct Known Subclasses

Pro::Routing::Features::Patterns::Patterns

Instance Method Summary

• #delete_if ⇒ Object

  Allows us to remove elements from the topics.

• #each ⇒ Object

  Yields each topic.

• #find(topic_name) ⇒ Karafka::Routing::Topic

  Finds topic by its name.

• #initialize(topics_array) ⇒ Topics constructor

  A new instance of Topics.

Constructor Details

#initialize(topics_array) ⇒ Topics

Returns a new instance of Topics.

Parameters:

• topics_array (Array<Karafka::Routing::Topic>) —

  array with topics

# File 'lib/karafka/routing/topics.rb', line 13

def initialize(topics_array)
  @accumulator = topics_array.dup
end

Instance Method Details

#delete_if ⇒ Object

Allows us to remove elements from the topics

Block to decide what to delete

# File 'lib/karafka/routing/topics.rb', line 25

def delete_if(&)
  @accumulator.delete_if(&)
end

#each ⇒ Object

Yields each topic

# File 'lib/karafka/routing/topics.rb', line 18

def each(&)
  @accumulator.each(&)
end

#find(topic_name) ⇒ Karafka::Routing::Topic

Finds topic by its name

Parameters:

• topic_name (String) —

  topic name

Returns:

• (Karafka::Routing::Topic)

Raises:

• (Karafka::Errors::TopicNotFoundError) —

  this should never happen. If you see it, please create an issue.

# File 'lib/karafka/routing/topics.rb', line 35

def find(topic_name)
  @accumulator.find { |topic| topic.name == topic_name } ||
    raise(Karafka::Errors::TopicNotFoundError, topic_name)
end