mirror of https://github.com/k3s-io/k3s
Make cloudcfg method switch idiomatic.
parent
02855cd096
commit
f6c4dd2332
|
@ -79,24 +79,25 @@ func main() {
|
||||||
log.Fatalf("Error loading auth: %#v", err)
|
log.Fatalf("Error loading auth: %#v", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
if method == "get" || method == "list" {
|
switch method {
|
||||||
|
case "get", "list":
|
||||||
if len(*labelQuery) > 0 && method == "list" {
|
if len(*labelQuery) > 0 && method == "list" {
|
||||||
url = url + "?labels=" + *labelQuery
|
url = url + "?labels=" + *labelQuery
|
||||||
}
|
}
|
||||||
request, err = http.NewRequest("GET", url, nil)
|
request, err = http.NewRequest("GET", url, nil)
|
||||||
} else if method == "delete" {
|
case "delete":
|
||||||
request, err = http.NewRequest("DELETE", url, nil)
|
request, err = http.NewRequest("DELETE", url, nil)
|
||||||
} else if method == "create" {
|
case "create":
|
||||||
request, err = cloudcfg.RequestWithBody(*config, url, "POST")
|
request, err = cloudcfg.RequestWithBody(*config, url, "POST")
|
||||||
} else if method == "update" {
|
case "update":
|
||||||
request, err = cloudcfg.RequestWithBody(*config, url, "PUT")
|
request, err = cloudcfg.RequestWithBody(*config, url, "PUT")
|
||||||
} else if method == "rollingupdate" {
|
case "rollingupdate":
|
||||||
client := &kube_client.Client{
|
client := &kube_client.Client{
|
||||||
Host: *httpServer,
|
Host: *httpServer,
|
||||||
Auth: &auth,
|
Auth: &auth,
|
||||||
}
|
}
|
||||||
cloudcfg.Update(flag.Arg(1), client, *updatePeriod)
|
cloudcfg.Update(flag.Arg(1), client, *updatePeriod)
|
||||||
} else if method == "run" {
|
case "run":
|
||||||
args := flag.Args()
|
args := flag.Args()
|
||||||
if len(args) < 4 {
|
if len(args) < 4 {
|
||||||
log.Fatal("usage: cloudcfg -h <host> run <image> <replicas> <name>")
|
log.Fatal("usage: cloudcfg -h <host> run <image> <replicas> <name>")
|
||||||
|
@ -112,19 +113,19 @@ func main() {
|
||||||
log.Fatalf("Error: %#v", err)
|
log.Fatalf("Error: %#v", err)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
} else if method == "stop" {
|
case "stop":
|
||||||
err = cloudcfg.StopController(flag.Arg(1), kube_client.Client{Host: *httpServer, Auth: &auth})
|
err = cloudcfg.StopController(flag.Arg(1), kube_client.Client{Host: *httpServer, Auth: &auth})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("Error: %#v", err)
|
log.Fatalf("Error: %#v", err)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
} else if method == "rm" {
|
case "rm":
|
||||||
err = cloudcfg.DeleteController(flag.Arg(1), kube_client.Client{Host: *httpServer, Auth: &auth})
|
err = cloudcfg.DeleteController(flag.Arg(1), kube_client.Client{Host: *httpServer, Auth: &auth})
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatalf("Error: %#v", err)
|
log.Fatalf("Error: %#v", err)
|
||||||
}
|
}
|
||||||
return
|
return
|
||||||
} else {
|
default:
|
||||||
log.Fatalf("Unknown command: %s", method)
|
log.Fatalf("Unknown command: %s", method)
|
||||||
}
|
}
|
||||||
if err != nil {
|
if err != nil {
|
||||||
|
|
Loading…
Reference in New Issue