INNER CODE UNIT · Ruby

query

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

      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)
      server_ids(server_name).each { |server_id| RocketJob::Subscribers::Server.publish(action, server_id: server_id) }
      # RocketJob::Subscribers::Worker.publish(:stop, worker_id: 1, server_id: RocketJob::Server.running.last.id)
      0
    end

View source record →