INNER CODE UNIT · Ruby

perform_server_action

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

    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

    # Returns server ids for the supplied exact server name, or partial match.
    #
    # When no ':' is supplied a partial hostname lookup is performed.
    #
    # Example: Exact server name (hostname and pid) match:
    #   "9cdbe7e995bc:1"
    #
    # Example: Matches all servers that contain the string '.batch.user.org':
    #   ".batch.user.org"
    def server_ids(server_name)
      raise(ArgumentError, "Missing server name") unless server_name

View source record →