@@ -19,13 +19,10 @@ package node
19
19
import (
20
20
"context"
21
21
"fmt"
22
- "os"
23
22
"path"
24
23
"time"
25
24
26
25
v1 "k8s.io/api/core/v1"
27
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
28
- "k8s.io/apimachinery/pkg/util/uuid"
29
26
"k8s.io/kubernetes/pkg/kubelet/images"
30
27
"k8s.io/kubernetes/test/e2e/framework"
31
28
e2epod "k8s.io/kubernetes/test/e2e/framework/pod"
@@ -262,7 +259,7 @@ while true; do sleep 1; done
262
259
// Images used for ConformanceContainer are not added into NodePrePullImageList, because this test is
263
260
// testing image pulling, these images don't need to be prepulled. The ImagePullPolicy
264
261
// is v1.PullAlways, so it won't be blocked by framework image pre-pull list check.
265
- imagePullTest := func (ctx context.Context , image string , hasSecret bool , expectedPhase v1.PodPhase , expectedPullStatus bool , windowsImage bool ) {
262
+ imagePullTest := func (ctx context.Context , image string , expectedPhase v1.PodPhase , expectedPullStatus bool , windowsImage bool ) {
266
263
command := []string {"/bin/sh" , "-c" , "while true; do sleep 1; done" }
267
264
if windowsImage {
268
265
// -t: Ping the specified host until stopped.
@@ -278,34 +275,7 @@ while true; do sleep 1; done
278
275
},
279
276
RestartPolicy : v1 .RestartPolicyNever ,
280
277
}
281
- if hasSecret {
282
- // The service account only has pull permission
283
- auth := `
284
- {
285
- "auths": {
286
- "https://gcr.io": {
287
- "auth": "X2pzb25fa2V5OnsKICAidHlwZSI6ICJzZXJ2aWNlX2FjY291bnQiLAogICJwcm9qZWN0X2lkIjogImF1dGhlbnRpY2F0ZWQtaW1hZ2UtcHVsbGluZyIsCiAgInByaXZhdGVfa2V5X2lkIjogImI5ZjJhNjY0YWE5YjIwNDg0Y2MxNTg2MDYzZmVmZGExOTIyNGFjM2IiLAogICJwcml2YXRlX2tleSI6ICItLS0tLUJFR0lOIFBSSVZBVEUgS0VZLS0tLS1cbk1JSUV2UUlCQURBTkJna3Foa2lHOXcwQkFRRUZBQVNDQktjd2dnU2pBZ0VBQW9JQkFRQzdTSG5LVEVFaVlMamZcbkpmQVBHbUozd3JCY2VJNTBKS0xxS21GWE5RL3REWGJRK2g5YVl4aldJTDhEeDBKZTc0bVovS01uV2dYRjVLWlNcbm9BNktuSU85Yi9SY1NlV2VpSXRSekkzL1lYVitPNkNjcmpKSXl4anFWam5mVzJpM3NhMzd0OUE5VEZkbGZycm5cbjR6UkpiOWl4eU1YNGJMdHFGR3ZCMDNOSWl0QTNzVlo1ODhrb1FBZmgzSmhhQmVnTWorWjRSYko0aGVpQlFUMDNcbnZVbzViRWFQZVQ5RE16bHdzZWFQV2dydDZOME9VRGNBRTl4bGNJek11MjUzUG4vSzgySFpydEx4akd2UkhNVXhcbng0ZjhwSnhmQ3h4QlN3Z1NORit3OWpkbXR2b0wwRmE3ZGducFJlODZWRDY2ejNZenJqNHlLRXRqc2hLZHl5VWRcbkl5cVhoN1JSQWdNQkFBRUNnZ0VBT3pzZHdaeENVVlFUeEFka2wvSTVTRFVidi9NazRwaWZxYjJEa2FnbmhFcG9cbjFJajJsNGlWMTByOS9uenJnY2p5VlBBd3pZWk1JeDFBZVF0RDdoUzRHWmFweXZKWUc3NkZpWFpQUm9DVlB6b3VcbmZyOGRDaWFwbDV0enJDOWx2QXNHd29DTTdJWVRjZmNWdDdjRTEyRDNRS3NGNlo3QjJ6ZmdLS251WVBmK0NFNlRcbmNNMHkwaCtYRS9kMERvSERoVy96YU1yWEhqOFRvd2V1eXRrYmJzNGYvOUZqOVBuU2dET1lQd2xhbFZUcitGUWFcbkpSd1ZqVmxYcEZBUW14M0Jyd25rWnQzQ2lXV2lGM2QrSGk5RXRVYnRWclcxYjZnK1JRT0licWFtcis4YlJuZFhcbjZWZ3FCQWtKWjhSVnlkeFVQMGQxMUdqdU9QRHhCbkhCbmM0UW9rSXJFUUtCZ1FEMUNlaWN1ZGhXdGc0K2dTeGJcbnplanh0VjFONDFtZHVjQnpvMmp5b1dHbzNQVDh3ckJPL3lRRTM0cU9WSi9pZCs4SThoWjRvSWh1K0pBMDBzNmdcblRuSXErdi9kL1RFalk4MW5rWmlDa21SUFdiWHhhWXR4UjIxS1BYckxOTlFKS2ttOHRkeVh5UHFsOE1veUdmQ1dcbjJ2aVBKS05iNkhabnY5Q3lqZEo5ZzJMRG5RS0JnUUREcVN2eURtaGViOTIzSW96NGxlZ01SK205Z2xYVWdTS2dcbkVzZlllbVJmbU5XQitDN3ZhSXlVUm1ZNU55TXhmQlZXc3dXRldLYXhjK0krYnFzZmx6elZZdFpwMThNR2pzTURcbmZlZWZBWDZCWk1zVXQ3Qmw3WjlWSjg1bnRFZHFBQ0xwWitaLzN0SVJWdWdDV1pRMWhrbmxHa0dUMDI0SkVFKytcbk55SDFnM2QzUlFLQmdRQ1J2MXdKWkkwbVBsRklva0tGTkh1YTBUcDNLb1JTU1hzTURTVk9NK2xIckcxWHJtRjZcbkMwNGNTKzQ0N0dMUkxHOFVUaEpKbTRxckh0Ti9aK2dZOTYvMm1xYjRIakpORDM3TVhKQnZFYTN5ZUxTOHEvK1JcbjJGOU1LamRRaU5LWnhQcG84VzhOSlREWTVOa1BaZGh4a2pzSHdVNGRTNjZwMVRESUU0MGd0TFpaRFFLQmdGaldcbktyblFpTnEzOS9iNm5QOFJNVGJDUUFKbmR3anhTUU5kQTVmcW1rQTlhRk9HbCtqamsxQ1BWa0tNSWxLSmdEYkpcbk9heDl2OUc2Ui9NSTFIR1hmV3QxWU56VnRocjRIdHNyQTB0U3BsbWhwZ05XRTZWejZuQURqdGZQSnMyZUdqdlhcbmpQUnArdjhjY21MK3dTZzhQTGprM3ZsN2VlNXJsWWxNQndNdUdjUHhBb0dBZWRueGJXMVJMbVZubEFpSEx1L0xcbmxtZkF3RFdtRWlJMFVnK1BMbm9Pdk81dFE1ZDRXMS94RU44bFA0cWtzcGtmZk1Rbk5oNFNZR0VlQlQzMlpxQ1RcbkpSZ2YwWGpveXZ2dXA5eFhqTWtYcnBZL3ljMXpmcVRaQzBNTzkvMVVjMWJSR2RaMmR5M2xSNU5XYXA3T1h5Zk9cblBQcE5Gb1BUWGd2M3FDcW5sTEhyR3pNPVxuLS0tLS1FTkQgUFJJVkFURSBLRVktLS0tLVxuIiwKICAiY2xpZW50X2VtYWlsIjogImltYWdlLXB1bGxpbmdAYXV0aGVudGljYXRlZC1pbWFnZS1wdWxsaW5nLmlhbS5nc2VydmljZWFjY291bnQuY29tIiwKICAiY2xpZW50X2lkIjogIjExMzc5NzkxNDUzMDA3MzI3ODcxMiIsCiAgImF1dGhfdXJpIjogImh0dHBzOi8vYWNjb3VudHMuZ29vZ2xlLmNvbS9vL29hdXRoMi9hdXRoIiwKICAidG9rZW5fdXJpIjogImh0dHBzOi8vYWNjb3VudHMuZ29vZ2xlLmNvbS9vL29hdXRoMi90b2tlbiIsCiAgImF1dGhfcHJvdmlkZXJfeDUwOV9jZXJ0X3VybCI6ICJodHRwczovL3d3dy5nb29nbGVhcGlzLmNvbS9vYXV0aDIvdjEvY2VydHMiLAogICJjbGllbnRfeDUwOV9jZXJ0X3VybCI6ICJodHRwczovL3d3dy5nb29nbGVhcGlzLmNvbS9yb2JvdC92MS9tZXRhZGF0YS94NTA5L2ltYWdlLXB1bGxpbmclNDBhdXRoZW50aWNhdGVkLWltYWdlLXB1bGxpbmcuaWFtLmdzZXJ2aWNlYWNjb3VudC5jb20iCn0=",
288
- "email": "image-pulling@authenticated-image-pulling.iam.gserviceaccount.com"
289
- }
290
- }
291
- }`
292
- // we might be told to use a different docker config JSON.
293
- if framework .TestContext .DockerConfigFile != "" {
294
- contents , err := os .ReadFile (framework .TestContext .DockerConfigFile )
295
- framework .ExpectNoError (err )
296
- auth = string (contents )
297
- }
298
- secret := & v1.Secret {
299
- Data : map [string ][]byte {v1 .DockerConfigJsonKey : []byte (auth )},
300
- Type : v1 .SecretTypeDockerConfigJson ,
301
- }
302
- secret .Name = "image-pull-secret-" + string (uuid .NewUUID ())
303
- ginkgo .By ("create image pull secret" )
304
- _ , err := f .ClientSet .CoreV1 ().Secrets (f .Namespace .Name ).Create (ctx , secret , metav1.CreateOptions {})
305
- framework .ExpectNoError (err )
306
- ginkgo .DeferCleanup (f .ClientSet .CoreV1 ().Secrets (f .Namespace .Name ).Delete , secret .Name , metav1.DeleteOptions {})
307
- container .ImagePullSecrets = []string {secret .Name }
308
- }
278
+
309
279
// checkContainerStatus checks whether the container status matches expectation.
310
280
checkContainerStatus := func (ctx context.Context ) error {
311
281
status , err := container .GetStatus (ctx )
@@ -370,29 +340,24 @@ while true; do sleep 1; done
370
340
371
341
f .It ("should not be able to pull image from invalid registry" , f .WithNodeConformance (), func (ctx context.Context ) {
372
342
image := imageutils .GetE2EImage (imageutils .InvalidRegistryImage )
373
- imagePullTest (ctx , image , false , v1 .PodPending , true , false )
343
+ imagePullTest (ctx , image , v1 .PodPending , true , false )
374
344
})
375
345
376
346
f .It ("should be able to pull image" , f .WithNodeConformance (), func (ctx context.Context ) {
377
347
// NOTE(claudiub): The agnhost image is supposed to work on both Linux and Windows.
378
348
image := imageutils .GetE2EImage (imageutils .Agnhost )
379
- imagePullTest (ctx , image , false , v1 .PodRunning , false , false )
349
+ imagePullTest (ctx , image , v1 .PodRunning , false , false )
380
350
})
381
351
352
+ // TODO: https://github.com/kubernetes/kubernetes/issues/130271
353
+ // Switch this to use a locally hosted private image and not depend on this host
382
354
f .It ("should not be able to pull from private registry without secret" , f .WithNodeConformance (), func (ctx context.Context ) {
383
355
image := imageutils .GetE2EImage (imageutils .AuthenticatedAlpine )
384
- imagePullTest (ctx , image , false , v1 .PodPending , true , false )
356
+ imagePullTest (ctx , image , v1 .PodPending , true , false )
385
357
})
386
358
387
- f .It ("should be able to pull from private registry with secret" , f .WithNodeConformance (), func (ctx context.Context ) {
388
- image := imageutils .GetE2EImage (imageutils .AuthenticatedAlpine )
389
- isWindows := false
390
- if framework .NodeOSDistroIs ("windows" ) {
391
- image = imageutils .GetE2EImage (imageutils .AuthenticatedWindowsNanoServer )
392
- isWindows = true
393
- }
394
- imagePullTest (ctx , image , true , v1 .PodRunning , false , isWindows )
395
- })
359
+ // TODO: https://github.com/kubernetes/kubernetes/issues/130271
360
+ // Add a sustainable test for pulling with a private registry secret
396
361
})
397
362
})
398
363
})
0 commit comments