forked from openshift/origin
-
Notifications
You must be signed in to change notification settings - Fork 1
/
apply_list.go
113 lines (91 loc) · 2.53 KB
/
apply_list.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
package componentinstall
import (
"io/ioutil"
"path"
"path/filepath"
"time"
"github.com/golang/glog"
"k8s.io/apimachinery/pkg/util/wait"
"github.com/openshift/origin/pkg/oc/clusterup/coreinstall/kubeapiserver"
"github.com/openshift/origin/pkg/oc/clusterup/docker/dockerhelper"
"github.com/openshift/origin/pkg/oc/clusterup/docker/run"
"github.com/openshift/origin/pkg/oc/errors"
)
type List struct {
Name string
Namespace string
List []byte
WaitCondition func() (bool, error)
}
func (t List) MakeReady(image, baseDir string) Component {
return &installReadyList{
list: t,
image: image,
baseDir: baseDir,
}
}
const listBashScript = `#!/bin/sh
set -e
set -x
ls -alh /
ns=""
if [ -s /namespace-file ]; then
ns="--namespace=$(cat /namespace-file) "
fi
oc apply ${ns} --config=/kubeconfig.kubeconfig -f /list.yaml
`
type installReadyList struct {
list List
image string
baseDir string
}
func (opt *installReadyList) Name() string {
return opt.list.Name
}
func (opt *installReadyList) Install(dockerClient dockerhelper.Interface) error {
imageRunHelper := run.NewRunHelper(dockerhelper.NewHelper(dockerClient)).New()
clusterAdminConfigBytes, err := ioutil.ReadFile(path.Join(opt.baseDir, kubeapiserver.KubeAPIServerDirName, "admin.kubeconfig"))
if err != nil {
return err
}
glog.Infof("Installing %q", opt.Name())
contentToCopy := map[string][]byte{
"kubeconfig.kubeconfig": clusterAdminConfigBytes,
"list.yaml": opt.list.List,
"apply.sh": []byte(listBashScript),
"namespace-file": []byte(opt.list.Namespace),
}
var lastErr error
// do a very simple retry loop on failure. Three times, ten second gaps
wait.PollImmediate(10*time.Second, 30*time.Second, func() (bool, error) {
_, rc, err := imageRunHelper.Image(opt.image).
Privileged().
DiscardContainer().
Copy(contentToCopy).
HostNetwork().
HostPid().
Entrypoint("sh").
SaveContainerLogs(opt.Name(), filepath.Join(opt.baseDir, "logs")).
Command("-c", "chmod 755 /apply.sh && /apply.sh").Run()
if err != nil {
lastErr = errors.NewError("failed to install %q: %v", opt.Name(), err).WithCause(err)
return false, nil
}
if rc != 0 {
lastErr = errors.NewError("failed to install %q: rc: %d", opt.Name(), rc)
return false, nil
}
lastErr = nil
return true, nil
})
if lastErr != nil {
return lastErr
}
if opt.list.WaitCondition == nil {
return nil
}
if err := wait.PollImmediate(time.Second, 5*time.Minute, opt.list.WaitCondition); err != nil {
return err
}
return nil
}