Class: Karafka::Web::Pro::Commanding::Commands::Partitions::Seek

Inherits:
Base
  • Object
show all
Defined in:
lib/karafka/web/pro/commanding/commands/partitions/seek.rb

Overview

Topic partition seek command request handler

Instance Attribute Summary

Attributes inherited from Base

#command

Instance Method Summary collapse

Methods inherited from Base

#initialize

Constructor Details

This class inherits a constructor from Karafka::Web::Pro::Commanding::Commands::Base

Instance Method Details

#call ⇒ Object

Dispatches the seek request into the appropriate filter and indicates that the seeking is in an acceptance state



18
19
20
21
22
23
 
# File 'lib/karafka/web/pro/commanding/commands/partitions/seek.rb', line 18

def call
  Handlers::Partitions::Tracker.instance << command

  # Publish back info on who did this with all the details for inspection
  acceptance(command.to_h)
end