c2d7fd775f
When stopping or starting Traefik, don't hide important errors. Docker doesn't return an error when starting a started container or stopping a stopped container. When rebooting we want to know about errors during run as we've just stopped and removed the previous container. When booting, we want to leave the running container if it exists, restart a stopped container and run a new one if none exists. We can implement this with `docker start ... || docker run ...`: - if the container is started, `docker start` will exit with 0 - if the container is stopped, `docker start` will start it and exit with 0 - if the container doesn't exist, `docker start` will return a non zero exit code and `docker run` will create a new container. Any errors in `docker run` will be returned.
112 lines
3.5 KiB
Ruby
112 lines
3.5 KiB
Ruby
class Mrsk::Cli::Traefik < Mrsk::Cli::Base
|
|
desc "boot", "Boot Traefik on servers"
|
|
def boot
|
|
mutating do
|
|
on(MRSK.traefik_hosts) do
|
|
execute *MRSK.registry.login
|
|
execute *MRSK.traefik.start_or_run
|
|
end
|
|
end
|
|
end
|
|
|
|
desc "reboot", "Reboot Traefik on servers (stop container, remove container, start new container)"
|
|
option :rolling, type: :boolean, default: false, desc: "Reboot traefik on hosts in sequence, rather than in parallel"
|
|
def reboot
|
|
mutating do
|
|
on(MRSK.traefik_hosts, in: options[:rolling] ? :sequence : :parallel) do
|
|
execute *MRSK.auditor.record("Rebooted traefik"), verbosity: :debug
|
|
execute *MRSK.registry.login
|
|
execute *MRSK.traefik.stop
|
|
execute *MRSK.traefik.remove_container
|
|
execute *MRSK.traefik.run
|
|
end
|
|
end
|
|
end
|
|
|
|
desc "start", "Start existing Traefik container on servers"
|
|
def start
|
|
mutating do
|
|
on(MRSK.traefik_hosts) do
|
|
execute *MRSK.auditor.record("Started traefik"), verbosity: :debug
|
|
execute *MRSK.traefik.start
|
|
end
|
|
end
|
|
end
|
|
|
|
desc "stop", "Stop existing Traefik container on servers"
|
|
def stop
|
|
mutating do
|
|
on(MRSK.traefik_hosts) do
|
|
execute *MRSK.auditor.record("Stopped traefik"), verbosity: :debug
|
|
execute *MRSK.traefik.stop
|
|
end
|
|
end
|
|
end
|
|
|
|
desc "restart", "Restart existing Traefik container on servers"
|
|
def restart
|
|
mutating do
|
|
stop
|
|
start
|
|
end
|
|
end
|
|
|
|
desc "details", "Show details about Traefik container from servers"
|
|
def details
|
|
on(MRSK.traefik_hosts) { |host| puts_by_host host, capture_with_info(*MRSK.traefik.info), type: "Traefik" }
|
|
end
|
|
|
|
desc "logs", "Show log lines from Traefik on servers"
|
|
option :since, aliases: "-s", desc: "Show logs since timestamp (e.g. 2013-01-02T13:23:37Z) or relative (e.g. 42m for 42 minutes)"
|
|
option :lines, type: :numeric, aliases: "-n", desc: "Number of log lines to pull from each server"
|
|
option :grep, aliases: "-g", desc: "Show lines with grep match only (use this to fetch specific requests by id)"
|
|
option :follow, aliases: "-f", desc: "Follow logs on primary server (or specific host set by --hosts)"
|
|
def logs
|
|
grep = options[:grep]
|
|
|
|
if options[:follow]
|
|
run_locally do
|
|
info "Following logs on #{MRSK.primary_host}..."
|
|
info MRSK.traefik.follow_logs(host: MRSK.primary_host, grep: grep)
|
|
exec MRSK.traefik.follow_logs(host: MRSK.primary_host, grep: grep)
|
|
end
|
|
else
|
|
since = options[:since]
|
|
lines = options[:lines].presence || ((since || grep) ? nil : 100) # Default to 100 lines if since or grep isn't set
|
|
|
|
on(MRSK.traefik_hosts) do |host|
|
|
puts_by_host host, capture(*MRSK.traefik.logs(since: since, lines: lines, grep: grep)), type: "Traefik"
|
|
end
|
|
end
|
|
end
|
|
|
|
desc "remove", "Remove Traefik container and image from servers"
|
|
def remove
|
|
mutating do
|
|
stop
|
|
remove_container
|
|
remove_image
|
|
end
|
|
end
|
|
|
|
desc "remove_container", "Remove Traefik container from servers", hide: true
|
|
def remove_container
|
|
mutating do
|
|
on(MRSK.traefik_hosts) do
|
|
execute *MRSK.auditor.record("Removed traefik container"), verbosity: :debug
|
|
execute *MRSK.traefik.remove_container
|
|
end
|
|
end
|
|
end
|
|
|
|
desc "remove_image", "Remove Traefik image from servers", hide: true
|
|
def remove_image
|
|
mutating do
|
|
on(MRSK.traefik_hosts) do
|
|
execute *MRSK.auditor.record("Removed traefik image"), verbosity: :debug
|
|
execute *MRSK.traefik.remove_image
|
|
end
|
|
end
|
|
end
|
|
end
|