Class: Karafka::BaseResponder

Inherits:
Object
  • Object
show all
Defined in:
lib/karafka/base_responder.rb

Overview

Base responder from which all Karafka responders should inherit Similar to Rails responders concept. It allows us to design flow from one app to another by isolating what responses should be sent (and where) based on a given action It differs from Rails responders in the way it works: in std http request we can have one response, here we can have unlimited number of them

It has a simple API for defining where should we respond (and if it is required)

Examples:

Basic usage (each registered topic is required to be used by default)

class Responder < BaseResponder
  topic :new_action

  def respond(data)
    respond_to :new_action, data
  end
end

Marking topic as not required (we won’t have to use it)

class Responder < BaseResponder
  topic :required_topic
  topic :new_action, required: false

  def respond(data)
    respond_to :required_topic, data
  end
end

Multiple times used topic

class Responder < BaseResponder
  topic :required_topic, multiple_usage: true

  def respond(data)
    data.each do |subset|
      respond_to :required_topic, subset
    end
  end
end

Accept multiple arguments to a respond method

class Responder < BaseResponder
  topic :users_actions
  topic :articles_viewed

  def respond(user, article)
    respond_to :users_actions, user
    respond_to :articles_viewed, article
  end
end

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Karafka::BaseResponder

Creates a responder object



69
70
71
 
# File 'lib/karafka/base_responder.rb', line 69

def initialize
  @messages_buffer = {}
end

Instance Attribute Details

#messages_buffer ⇒ Object (readonly)

Returns the value of attribute messages_buffer.



54
55
56
 
# File 'lib/karafka/base_responder.rb', line 54

def messages_buffer
  @messages_buffer
end

Class Method Details

.topic(topic_name, options = {}) ⇒ Object

Registers a topic as on to which we will be able to respond

Parameters:

  • topic_name (Symbol, String) —

    name of topic to which we want to respond

  • options (Hash) (defaults to: {}) —

    hash with optional configuration details



60
61
62
63
64
 
# File 'lib/karafka/base_responder.rb', line 60

def topic(topic_name, options = {})
  self.topics ||= {}
  topic_obj = Responders::Topic.new(topic_name, options)
  self.topics[topic_obj.name] = topic_obj
end

Instance Method Details

#call(*data) ⇒ Object

Note:

We know that validators should be executed also before sending data to topics, however the implementation gets way more complicated then, that’s why we check after everything was sent using responder

Performs respond and validates that all the response requirement were met

Parameters:

  • data —

    Anything that we want to respond with



78
79
80
81
82
 
# File 'lib/karafka/base_responder.rb', line 78

def call(*data)
  respond(*data)
  validate!
  deliver!
end