ridv/australis
1
0
Fork 0
Code Issues Pull requests Projects Releases 16 Packages Wiki Activity Actions

Adding support for reading JSON list of hosts to drain from STDIN or from a file.

Browse source
This commit is contained in:
Renan DelValle 2020-02-07 18:36:33 -08:00
parent b37462d006
commit 05557a65c8
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
1 changed files with 40 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

48
cmd/start.go
View file

@ -15,7 +15,10 @@
package cmd package cmd
import ( import (
"encoding/json"
"errors" "errors"
"io/ioutil"
"os"
"time" "time"
"github.com/paypal/gorealis/v2/gen-go/apache/aurora" "github.com/paypal/gorealis/v2/gen-go/apache/aurora"
@ -123,10 +126,36 @@ func argsValidateJSONFlags(cmd *cobra.Command, args []string) error {
return nil return nil
} }
func hostList(cmd *cobra.Command, args []string) []string {
var hosts []string
if cmd.Flags().Changed(jsonFlag) {
err := json.NewDecoder(os.Stdin).Decode(&hosts)
if err != nil {
log.Fatal(err)
}
} else if cmd.Flags().Changed(jsonFileFlag) {
data, err := ioutil.ReadFile(fromJsonFile)
if err != nil {
log.Fatal(err)
}
err = json.Unmarshal(data, &hosts)
if err != nil {
log.Fatal(err)
}
} else {
hosts = args
}
return hosts
}
func drain(cmd *cobra.Command, args []string) { func drain(cmd *cobra.Command, args []string) {
hosts := hostList(cmd, args)
log.Infoln("Setting hosts to DRAINING") log.Infoln("Setting hosts to DRAINING")
log.Infoln(args) log.Infoln(hosts)
result, err := client.DrainHosts(args...) result, err := client.DrainHosts(hosts...)
if err != nil { if err != nil {
log.Fatalf("error: %+v", err) log.Fatalf("error: %+v", err)
} }
@ -136,7 +165,7 @@ func drain(cmd *cobra.Command, args []string) {
log.Infof("Monitoring for %v at %v intervals", monitorHostCmd.monitorTimeout, monitorHostCmd.monitorInterval) log.Infof("Monitoring for %v at %v intervals", monitorHostCmd.monitorTimeout, monitorHostCmd.monitorInterval)
// Monitor change to DRAINING and DRAINED mode // Monitor change to DRAINING and DRAINED mode
hostResult, err := client.MonitorHostMaintenance( hostResult, err := client.MonitorHostMaintenance(
args, hosts,
[]aurora.MaintenanceMode{aurora.MaintenanceMode_DRAINED}, []aurora.MaintenanceMode{aurora.MaintenanceMode_DRAINED},
startDrainCmd.monitorInterval, startDrainCmd.monitorInterval,
startDrainCmd.monitorTimeout) startDrainCmd.monitorTimeout)
@ -149,7 +178,6 @@ func drain(cmd *cobra.Command, args []string) {
} }
func slaDrainHosts(policy *aurora.SlaPolicy, interval, timeout time.Duration, hosts ...string) { func slaDrainHosts(policy *aurora.SlaPolicy, interval, timeout time.Duration, hosts ...string) {
result, err := client.SLADrainHosts(policy, int64(forceDrainTimeout.Seconds()), hosts...) result, err := client.SLADrainHosts(policy, int64(forceDrainTimeout.Seconds()), hosts...)
if err != nil { if err != nil {
log.Fatalf("error: %+v\n", err) log.Fatalf("error: %+v\n", err)
@ -172,6 +200,8 @@ func slaDrainHosts(policy *aurora.SlaPolicy, interval, timeout time.Duration, ho
} }
} }
func slaDrain(cmd *cobra.Command, args []string) { func slaDrain(cmd *cobra.Command, args []string) {
hosts := hostList(cmd, args)
// This check makes sure only a single flag is set. // This check makes sure only a single flag is set.
// If they're both set or both not set, the statement will evaluate to true. // If they're both set or both not set, the statement will evaluate to true.
if cmd.Flags().Changed(percentageFlag) == cmd.Flags().Changed(countFlag) { if cmd.Flags().Changed(percentageFlag) == cmd.Flags().Changed(countFlag) {
@ -194,13 +224,15 @@ func slaDrain(cmd *cobra.Command, args []string) {
} }
log.Infoln("Hosts affected: ", args) log.Infoln("Hosts affected: ", args)
slaDrainHosts(policy, startDrainCmd.monitorInterval, startDrainCmd.monitorTimeout, args...) slaDrainHosts(policy, startDrainCmd.monitorInterval, startDrainCmd.monitorTimeout, hosts...)
} }
func maintenance(cmd *cobra.Command, args []string) { func maintenance(cmd *cobra.Command, args []string) {
hosts := hostList(cmd, args)
log.Infoln("Setting hosts to Maintenance mode") log.Infoln("Setting hosts to Maintenance mode")
log.Infoln(args) log.Infoln(hosts)
result, err := client.StartMaintenance(args...) result, err := client.StartMaintenance(hosts...)
if err != nil { if err != nil {
log.Fatalf("error: %+v", err) log.Fatalf("error: %+v", err)
} }
@ -211,7 +243,7 @@ func maintenance(cmd *cobra.Command, args []string) {
// Monitor change to DRAINING and DRAINED mode // Monitor change to DRAINING and DRAINED mode
hostResult, err := client.MonitorHostMaintenance( hostResult, err := client.MonitorHostMaintenance(
args, hosts,
[]aurora.MaintenanceMode{aurora.MaintenanceMode_SCHEDULED}, []aurora.MaintenanceMode{aurora.MaintenanceMode_SCHEDULED},
startMaintenanceCmd.monitorInterval, startMaintenanceCmd.monitorInterval,
startMaintenanceCmd.monitorTimeout) startMaintenanceCmd.monitorTimeout)