INNER CODE UNIT · Ruby

list_the_servers

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

    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}"
        duration  = Time.now - (server.started_at || Time.now)
        started   = "#{RocketJob.seconds_as_duration(duration)} ago"
        duration  = Time.now - (server&.heartbeat&.updated_at || Time.now)
        heartbeat = "#{RocketJob.seconds_as_duration(duration)} ago"
        puts format(layout, server.name, workers, started, heartbeat, server.state)
      end
      0
    end

    def perform_server_action(server_name, action)

View source record →