rabbitmq-server/deps/rabbitmq_cli/lib/cli.ex

39 lines
959 B
Elixir
Raw Normal View History

2016-02-03 02:54:36 +08:00
defmodule CLI do
import Parser
import Helpers
import StatusCommand
def main(command) do
2016-02-03 05:26:10 +08:00
:net_kernel.start([:rabbitmqctl, :shortnames])
2016-02-03 02:54:36 +08:00
{parsed_cmd, options} = parse(command)
case options[:node] do
2016-02-03 05:26:10 +08:00
nil -> connect_to_rabbitmq |> IO.puts
_ -> options[:node] |> String.to_atom |> connect_to_rabbitmq |> IO.puts
2016-02-03 02:54:36 +08:00
end
run_command(parsed_cmd, options)
:net_kernel.stop()
end
2016-02-03 05:32:35 +08:00
defp print_usage() do
IO.puts "Usage: TBD"
end
2016-02-03 02:54:36 +08:00
defp print_nodedown_error(options) do
2016-02-03 05:26:10 +08:00
target_node = options[:node] || get_rabbit_hostname
2016-02-03 02:54:36 +08:00
IO.puts "Status of #{target_node} ..."
IO.puts "Error: unable to connect to node '#{target_node}': nodedown"
end
2016-02-03 05:32:35 +08:00
defp run_command([], _), do: IO.puts print_usage
2016-02-03 02:54:36 +08:00
defp run_command(["status"], options) do
case result = status(options) do
2016-02-03 05:26:10 +08:00
{:badrpc, :nodedown} -> print_nodedown_error(options)
_ -> print_status(result)
2016-02-03 02:54:36 +08:00
end
end
end