@@ -103,7 +103,7 @@ func TestRayClusterWebhookDefault(t *testing.T) {
103
103
To (
104
104
And (
105
105
HaveLen (1 ),
106
- ContainElement (WithTransform (ContainerName , Equal (oauthProxyContainerName ))),
106
+ ContainElement (WithTransform (support . ResourceName , Equal (oauthProxyContainerName ))),
107
107
),
108
108
"Expected the OAuth proxy container to be present in the head group" ,
109
109
)
@@ -114,9 +114,9 @@ func TestRayClusterWebhookDefault(t *testing.T) {
114
114
To (
115
115
And (
116
116
HaveLen (3 ),
117
- ContainElement (WithTransform (VolumeName , Equal (oauthProxyVolumeName ))),
118
- ContainElement (WithTransform (VolumeName , Equal ("ca-vol" ))),
119
- ContainElement (WithTransform (VolumeName , Equal ("server-cert" ))),
117
+ ContainElement (WithTransform (support . ResourceName , Equal (oauthProxyVolumeName ))),
118
+ ContainElement (WithTransform (support . ResourceName , Equal ("ca-vol" ))),
119
+ ContainElement (WithTransform (support . ResourceName , Equal ("server-cert" ))),
120
120
),
121
121
"Expected the OAuth proxy TLS secret and CA volumes to be present in the head group" ,
122
122
)
@@ -133,12 +133,12 @@ func TestRayClusterWebhookDefault(t *testing.T) {
133
133
To (
134
134
And (
135
135
HaveLen (6 ),
136
- ContainElement (WithTransform (EnvVarName , Equal ("COOKIE_SECRET" ))),
137
- ContainElement (WithTransform (EnvVarName , Equal ("MY_POD_IP" ))),
138
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_USE_TLS" ))),
139
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_TLS_SERVER_CERT" ))),
140
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_TLS_SERVER_KEY" ))),
141
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_TLS_CA_CERT" ))),
136
+ ContainElement (WithTransform (support . ResourceName , Equal ("COOKIE_SECRET" ))),
137
+ ContainElement (WithTransform (support . ResourceName , Equal ("MY_POD_IP" ))),
138
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_USE_TLS" ))),
139
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_TLS_SERVER_CERT" ))),
140
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_TLS_SERVER_KEY" ))),
141
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_TLS_CA_CERT" ))),
142
142
),
143
143
"Expected the required environment variables to be present in the head group" ,
144
144
)
@@ -149,7 +149,7 @@ func TestRayClusterWebhookDefault(t *testing.T) {
149
149
To (
150
150
And (
151
151
HaveLen (1 ),
152
- ContainElement (WithTransform (ContainerName , Equal (initContainerName ))),
152
+ ContainElement (WithTransform (support . ResourceName , Equal (initContainerName ))),
153
153
),
154
154
"Expected the create-cert init container to be present in the head group" ,
155
155
)
@@ -160,9 +160,9 @@ func TestRayClusterWebhookDefault(t *testing.T) {
160
160
To (
161
161
And (
162
162
HaveLen (3 ),
163
- ContainElement (WithTransform (VolumeMountName , Equal (oauthProxyVolumeName ))),
164
- ContainElement (WithTransform (VolumeMountName , Equal ("ca-vol" ))),
165
- ContainElement (WithTransform (VolumeMountName , Equal ("server-cert" ))),
163
+ ContainElement (WithTransform (support . ResourceName , Equal (oauthProxyVolumeName ))),
164
+ ContainElement (WithTransform (support . ResourceName , Equal ("ca-vol" ))),
165
+ ContainElement (WithTransform (support . ResourceName , Equal ("server-cert" ))),
166
166
),
167
167
"Expected the OAuth proxy TLS secret and CA volume mounts to be present in the head group" ,
168
168
)
@@ -174,11 +174,11 @@ func TestRayClusterWebhookDefault(t *testing.T) {
174
174
To (
175
175
And (
176
176
HaveLen (5 ),
177
- ContainElement (WithTransform (EnvVarName , Equal ("MY_POD_IP" ))),
178
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_USE_TLS" ))),
179
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_TLS_SERVER_CERT" ))),
180
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_TLS_SERVER_KEY" ))),
181
- ContainElement (WithTransform (EnvVarName , Equal ("RAY_TLS_CA_CERT" ))),
177
+ ContainElement (WithTransform (support . ResourceName , Equal ("MY_POD_IP" ))),
178
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_USE_TLS" ))),
179
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_TLS_SERVER_CERT" ))),
180
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_TLS_SERVER_KEY" ))),
181
+ ContainElement (WithTransform (support . ResourceName , Equal ("RAY_TLS_CA_CERT" ))),
182
182
),
183
183
"Expected the required environment variables to be present in each worker group" ,
184
184
)
@@ -191,8 +191,8 @@ func TestRayClusterWebhookDefault(t *testing.T) {
191
191
To (
192
192
And (
193
193
HaveLen (2 ),
194
- ContainElement (WithTransform (VolumeName , Equal ("ca-vol" ))),
195
- ContainElement (WithTransform (VolumeName , Equal ("server-cert" ))),
194
+ ContainElement (WithTransform (support . ResourceName , Equal ("ca-vol" ))),
195
+ ContainElement (WithTransform (support . ResourceName , Equal ("server-cert" ))),
196
196
),
197
197
"Expected the required CA volumes to be present in each worker group" ,
198
198
)
@@ -205,8 +205,8 @@ func TestRayClusterWebhookDefault(t *testing.T) {
205
205
To (
206
206
And (
207
207
HaveLen (2 ),
208
- ContainElement (WithTransform (VolumeMountName , Equal ("ca-vol" ))),
209
- ContainElement (WithTransform (VolumeMountName , Equal ("server-cert" ))),
208
+ ContainElement (WithTransform (support . ResourceName , Equal ("ca-vol" ))),
209
+ ContainElement (WithTransform (support . ResourceName , Equal ("server-cert" ))),
210
210
),
211
211
"Expected the required certificate volume mounts to be present in each worker group" ,
212
212
)
@@ -219,7 +219,7 @@ func TestRayClusterWebhookDefault(t *testing.T) {
219
219
To (
220
220
And (
221
221
HaveLen (1 ),
222
- ContainElement (WithTransform (ContainerName , Equal (initContainerName ))),
222
+ ContainElement (WithTransform (support . ResourceName , Equal (initContainerName ))),
223
223
),
224
224
"Expected the required init container to be present in each worker group" ,
225
225
)
@@ -645,23 +645,3 @@ func TestValidateUpdate(t *testing.T) {
645
645
test .Expect (err ).Should (HaveOccurred (), "Expected errors on call to ValidateUpdate function due to manipulated env vars in the worker group" )
646
646
})
647
647
}
648
-
649
- func ContainerName (container corev1.Container ) string {
650
- return container .Name
651
- }
652
-
653
- func VolumeName (volume corev1.Volume ) string {
654
- return volume .Name
655
- }
656
-
657
- func ServiceAccountName (serviceAccount corev1.ServiceAccount ) string {
658
- return serviceAccount .Name
659
- }
660
-
661
- func VolumeMountName (volumeMount corev1.VolumeMount ) string {
662
- return volumeMount .Name
663
- }
664
-
665
- func EnvVarName (envVar corev1.EnvVar ) string {
666
- return envVar .Name
667
- }
0 commit comments