INNER CODE UNIT · Ruby

perform_list_servers

reidmorrison/rocketjob · lib/rocket_job/cli.rb:171

    def perform_list_servers(filter)
      return list_the_servers(filter) unless refresh

      loop do
        list_the_servers(filter)
        sleep(refresh)
        puts
      end
    end

    def list_the_servers(filter)
      layout = "%50.50s %20.20s %20.20s %20.20s %10.10s"
      puts format(layout, "Server Name", "Workers(Current/Max)", "Started", "Heartbeat", "State")
      header = "=" * 50
      puts format(layout, header, header, header, header, header)
      query = filter == :all ? RocketJob::Server.all : RocketJob::Server.where(name: /#{filter}/)
      query.each do |server|
        workers   = "#{server&.heartbeat&.workers}/#{server.max_workers}"

View source record →