forked from cloudfoundry/bosh-bootloader
/
bosh_executor.go
133 lines (113 loc) · 2.86 KB
/
bosh_executor.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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
package fakes
import (
"github.com/cloudfoundry/bosh-bootloader/bosh"
"github.com/cloudfoundry/bosh-bootloader/storage"
)
type BOSHExecutor struct {
CreateEnvCall struct {
CallCount int
Receives struct {
DirInput bosh.DirInput
State storage.State
}
Returns struct {
Variables string
Error error
}
}
DeleteEnvCall struct {
CallCount int
Receives struct {
DirInput bosh.DirInput
State storage.State
}
Returns struct {
Error error
}
}
PlanJumpboxCall struct {
CallCount int
Receives struct {
DirInput bosh.DirInput
DeploymentDir string
Iaas string
}
Returns struct {
Error error
}
}
PlanDirectorCall struct {
CallCount int
Receives struct {
DirInput bosh.DirInput
DeploymentDir string
Iaas string
}
Returns struct {
Error error
}
}
WriteDeploymentVarsCall struct {
CallCount int
Receives struct {
DirInput bosh.DirInput
DeploymentVars string
}
Returns struct {
Error error
}
}
PathCall struct {
CallCount int
Returns struct {
Path string
}
}
VersionCall struct {
CallCount int
Returns struct {
Version string
Error error
}
}
}
func (e *BOSHExecutor) WriteDeploymentVars(input bosh.DirInput, deploymentVars string) error {
e.WriteDeploymentVarsCall.CallCount++
e.WriteDeploymentVarsCall.Receives.DirInput = input
e.WriteDeploymentVarsCall.Receives.DeploymentVars = deploymentVars
return e.WriteDeploymentVarsCall.Returns.Error
}
func (e *BOSHExecutor) CreateEnv(input bosh.DirInput, state storage.State) (string, error) {
e.CreateEnvCall.CallCount++
e.CreateEnvCall.Receives.DirInput = input
e.CreateEnvCall.Receives.State = state
return e.CreateEnvCall.Returns.Variables, e.CreateEnvCall.Returns.Error
}
func (e *BOSHExecutor) DeleteEnv(input bosh.DirInput, state storage.State) error {
e.DeleteEnvCall.CallCount++
e.DeleteEnvCall.Receives.DirInput = input
e.DeleteEnvCall.Receives.State = state
return e.DeleteEnvCall.Returns.Error
}
func (e *BOSHExecutor) PlanJumpbox(input bosh.DirInput, deploymentDir, iaas string) error {
e.PlanJumpboxCall.CallCount++
e.PlanJumpboxCall.Receives.DirInput = input
e.PlanJumpboxCall.Receives.DeploymentDir = deploymentDir
e.PlanJumpboxCall.Receives.Iaas = iaas
return e.PlanJumpboxCall.Returns.Error
}
func (e *BOSHExecutor) PlanDirector(input bosh.DirInput, deploymentDir, iaas string) error {
e.PlanDirectorCall.CallCount++
e.PlanDirectorCall.Receives.DirInput = input
e.PlanDirectorCall.Receives.DeploymentDir = deploymentDir
e.PlanDirectorCall.Receives.Iaas = iaas
return e.PlanDirectorCall.Returns.Error
}
func (e *BOSHExecutor) Path() string {
e.PathCall.CallCount++
return e.PathCall.Returns.Path
}
func (e *BOSHExecutor) Version() (string, error) {
e.VersionCall.CallCount++
return e.VersionCall.Returns.Version, e.VersionCall.Returns.Error
}