ridv/gorealis-v2
1
0
Fork 0
Code Issues Pull requests Projects Releases 13 Packages Wiki Activity Actions

Making changes to sample client to match the refactoring done to main library.

Browse source
This commit is contained in:
Renan DelValle 2018-12-04 15:17:22 -08:00
parent 47d955d4a4
commit c00b83b14c
No known key found for this signature in database
GPG key ID: C240AD6D6F443EC9
1 changed files with 5 additions and 13 deletions
Download patch file Download diff file Expand all files Collapse all files

18
examples/client.go
View file

@ -243,19 +243,17 @@ func main() {
case "startCron": case "startCron":
fmt.Println("Starting a Cron job") fmt.Println("Starting a Cron job")
resp, err := r.StartCronJob(job.JobKey()) err := r.StartCronJob(job.JobKey())
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
fmt.Println(resp.String())
case "descheduleCron": case "descheduleCron":
fmt.Println("Descheduling a Cron job") fmt.Println("Descheduling a Cron job")
resp, err := r.DescheduleCronJob(job.JobKey()) err := r.DescheduleCronJob(job.JobKey())
if err != nil { if err != nil {
log.Fatal(err) log.Fatal(err)
} }
fmt.Println(resp.String())
case "kill": case "kill":
fmt.Println("Killing job") fmt.Println("Killing job")
@ -504,7 +502,7 @@ func main() {
log.Fatal("No hosts specified to drain") log.Fatal("No hosts specified to drain")
} }
hosts := strings.Split(hostList, ",") hosts := strings.Split(hostList, ",")
result, err := r.DrainHosts(hosts...) _, err := r.DrainHosts(hosts...)
if err != nil { if err != nil {
log.Fatalf("error: %+v\n", err.Error()) log.Fatalf("error: %+v\n", err.Error())
} }
@ -524,8 +522,6 @@ func main() {
log.Fatalf("error: %+v\n", err.Error()) log.Fatalf("error: %+v\n", err.Error())
} }
fmt.Print(result.String())
case "SLADrainHosts": case "SLADrainHosts":
fmt.Println("Setting hosts to DRAINING using SLA aware draining") fmt.Println("Setting hosts to DRAINING using SLA aware draining")
if hostList == "" { if hostList == "" {
@ -535,7 +531,7 @@ func main() {
policy := aurora.SlaPolicy{PercentageSlaPolicy: &aurora.PercentageSlaPolicy{Percentage: 50.0}} policy := aurora.SlaPolicy{PercentageSlaPolicy: &aurora.PercentageSlaPolicy{Percentage: 50.0}}
result, err := r.SLADrainHosts(&policy, 30, hosts...) _, err := r.SLADrainHosts(&policy, 30, hosts...)
if err != nil { if err != nil {
log.Fatalf("error: %+v\n", err.Error()) log.Fatalf("error: %+v\n", err.Error())
} }
@ -555,15 +551,13 @@ func main() {
log.Fatalf("error: %+v\n", err.Error()) log.Fatalf("error: %+v\n", err.Error())
} }
fmt.Print(result.String())
case "endMaintenance": case "endMaintenance":
fmt.Println("Setting hosts to ACTIVE") fmt.Println("Setting hosts to ACTIVE")
if hostList == "" { if hostList == "" {
log.Fatal("No hosts specified to drain") log.Fatal("No hosts specified to drain")
} }
hosts := strings.Split(hostList, ",") hosts := strings.Split(hostList, ",")
result, err := r.EndMaintenance(hosts...) _, err := r.EndMaintenance(hosts...)
if err != nil { if err != nil {
log.Fatalf("error: %+v\n", err.Error()) log.Fatalf("error: %+v\n", err.Error())
} }
@ -583,8 +577,6 @@ func main() {
log.Fatalf("error: %+v\n", err.Error()) log.Fatalf("error: %+v\n", err.Error())
} }
fmt.Print(result.String())
case "getPendingReasons": case "getPendingReasons":
fmt.Println("Getting pending reasons") fmt.Println("Getting pending reasons")
taskQ := &aurora.TaskQuery{ taskQ := &aurora.TaskQuery{