class Kafkat::ClusterRestart::Subcommands::Log

Attributes

session[R]

Public Instance Methods

run() click to toggle source
# File lib/kafkat/command/cluster_restart.rb, line 129
def run
  unless Session.exists?
    puts "ERROR: no session in progress"
    puts "\n[Action] Please run 'start' command"
    exit 1
  end

  @session = Session.load!
  puts JSON.pretty_generate(@session.to_h)
end