blob: 98254aef9a12b36bc199e89ac529af4c1f1226c6 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
|
package main
import (
"flag"
"log"
"check"
"check/rancher"
"check/raw"
"check/validators/master"
)
var (
ranchercli = flag.Bool("ranchercli", false, "use rancher utility for accessing cluster nodes")
rke = flag.Bool("rke", false, "use RKE cluster definition and ssh for accessing cluster nodes (default)")
)
func main() {
flag.Parse()
if *ranchercli && *rke {
log.Fatal("Not supported.")
}
// Use default cluster access method if none was declared explicitly.
if !(*ranchercli || *rke) {
*rke = true
}
var info check.Informer
switch {
case *ranchercli:
info = &rancher.Rancher{}
case *rke:
info = &raw.Raw{}
default:
log.Fatal("Missing cluster access method.")
}
apiParams, err := info.GetAPIParams()
if err != nil {
log.Fatal(err)
}
master.CheckAPI(apiParams)
schedulerParams, err := info.GetSchedulerParams()
if err != nil {
log.Fatal(err)
}
master.CheckScheduler(schedulerParams)
controllerManagerParams, err := info.GetControllerManagerParams()
if err != nil {
log.Fatal(err)
}
master.CheckControllerManager(controllerManagerParams)
_, err = info.GetEtcdParams()
if err != nil {
switch err {
case check.ErrNotImplemented:
log.Print(err) // Fail softly.
default:
log.Fatal(err)
}
}
}
|
