-
Notifications
You must be signed in to change notification settings - Fork 0
/
utils.go
117 lines (88 loc) · 2.47 KB
/
utils.go
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
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
package main
import (
"encoding/json"
"fmt"
"net/url"
"os"
"github.com/golang/glog"
apiv1 "k8s.io/api/core/v1"
)
// NodeFromJSON deserialize a string to apiv1.Node
func nodeFromJSON(s string) (*apiv1.Node, error) {
data := &apiv1.Node{}
err := json.Unmarshal([]byte(s), &data)
return data, err
}
func toJSON(v interface{}) string {
if v == nil {
return ""
}
b, _ := json.Marshal(v)
return string(b)
}
func getNodeProviderID(serverIdentifier string, node *apiv1.Node) string {
providerID := node.Spec.ProviderID
if len(providerID) == 0 {
nodegroupName := node.Labels[nodeLabelGroupName]
if len(nodegroupName) != 0 {
providerID = fmt.Sprintf("%s://%s/object?type=node&name=%s", serverIdentifier, nodegroupName, node.Name)
glog.Infof("Warning misconfiguration: node providerID: %s is extracted from node label.", providerID)
}
}
return providerID
}
func nodeGroupIDFromProviderID(serverIdentifier string, providerID string) (string, error) {
var nodeIdentifier *url.URL
var err error
if nodeIdentifier, err = url.ParseRequestURI(providerID); err != nil {
return "", err
}
if nodeIdentifier == nil {
return "", fmt.Errorf(errCantDecodeNodeID, providerID)
}
if nodeIdentifier.Scheme != serverIdentifier {
return "", fmt.Errorf(errWrongSchemeInProviderID, providerID, nodeIdentifier.Scheme)
}
if nodeIdentifier.Path != "object" && nodeIdentifier.Path != "/object" {
return "", fmt.Errorf(errWrongPathInProviderID, providerID, nodeIdentifier.Path)
}
return nodeIdentifier.Hostname(), nil
}
func nodeNameFromProviderID(serverIdentifier string, providerID string) (string, error) {
var nodeIdentifier *url.URL
var err error
if nodeIdentifier, err = url.ParseRequestURI(providerID); err != nil {
return "", err
}
if nodeIdentifier == nil {
return "", fmt.Errorf(errCantDecodeNodeID, providerID)
}
if nodeIdentifier.Scheme != serverIdentifier {
return "", fmt.Errorf(errWrongSchemeInProviderID, providerID, nodeIdentifier.Scheme)
}
if nodeIdentifier.Path != "object" && nodeIdentifier.Path != "/object" {
return "", fmt.Errorf(errWrongPathInProviderID, providerID, nodeIdentifier.Path)
}
return nodeIdentifier.Query().Get("name"), nil
}
func fileExists(name string) bool {
if len(name) == 0 {
return false
}
if _, err := os.Stat(name); err != nil && os.IsNotExist(err) {
return false
}
return true
}
func minInt(x, y int) int {
if x < y {
return x
}
return y
}
func maxInt(x, y int) int {
if x > y {
return x
}
return y
}