@@ -43,7 +43,7 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
43
43
it ("adds suffix to calculated name" , func () {
44
44
ref , err := name .ParseReference ("my/repo" , name .WeakValidation )
45
45
h .AssertNil (t , err )
46
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
46
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
47
47
if ! strings .HasSuffix (subject .Name (), ".some-suffix" ) {
48
48
t .Fatalf ("Calculated volume name '%s' should end with '.some-suffix'" , subject .Name ())
49
49
}
@@ -53,8 +53,8 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
53
53
ref , err := name .ParseReference ("my/repo" , name .WeakValidation )
54
54
h .AssertNil (t , err )
55
55
56
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
57
- expected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
56
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
57
+ expected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
58
58
if subject .Name () != expected .Name () {
59
59
t .Fatalf ("The same repo name should result in the same volume" )
60
60
}
@@ -64,11 +64,11 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
64
64
ref , err := name .ParseReference ("my/repo:other-tag" , name .WeakValidation )
65
65
h .AssertNil (t , err )
66
66
67
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
67
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
68
68
69
69
ref , err = name .ParseReference ("my/repo" , name .WeakValidation )
70
70
h .AssertNil (t , err )
71
- notExpected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
71
+ notExpected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
72
72
if subject .Name () == notExpected .Name () {
73
73
t .Fatalf ("Different image tags should result in different volumes" )
74
74
}
@@ -78,11 +78,11 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
78
78
ref , err := name .ParseReference ("registry.com/my/repo:other-tag" , name .WeakValidation )
79
79
h .AssertNil (t , err )
80
80
81
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
81
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
82
82
83
83
ref , err = name .ParseReference ("my/repo" , name .WeakValidation )
84
84
h .AssertNil (t , err )
85
- notExpected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
85
+ notExpected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
86
86
if subject .Name () == notExpected .Name () {
87
87
t .Fatalf ("Different image registries should result in different volumes" )
88
88
}
@@ -92,31 +92,31 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
92
92
ref , err := name .ParseReference ("my/repo:latest" , name .WeakValidation )
93
93
h .AssertNil (t , err )
94
94
95
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
95
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
96
96
97
97
ref , err = name .ParseReference ("my/repo" , name .WeakValidation )
98
98
h .AssertNil (t , err )
99
- expected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
99
+ expected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
100
100
h .AssertEq (t , subject .Name (), expected .Name ())
101
101
})
102
102
103
103
it ("resolves implied registry" , func () {
104
104
ref , err := name .ParseReference ("index.docker.io/my/repo" , name .WeakValidation )
105
105
h .AssertNil (t , err )
106
106
107
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
107
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
108
108
109
109
ref , err = name .ParseReference ("my/repo" , name .WeakValidation )
110
110
h .AssertNil (t , err )
111
- expected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
111
+ expected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
112
112
h .AssertEq (t , subject .Name (), expected .Name ())
113
113
})
114
114
115
115
it ("includes human readable information" , func () {
116
116
ref , err := name .ParseReference ("myregistryhost:5000/fedora/httpd:version1.0" , name .WeakValidation )
117
117
h .AssertNil (t , err )
118
118
119
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
119
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
120
120
121
121
h .AssertContains (t , subject .Name (), "fedora_httpd_version1.0" )
122
122
h .AssertTrue (t , names .RestrictedNamePattern .MatchString (subject .Name ()))
@@ -132,9 +132,9 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
132
132
ref , err := name .ParseReference ("my/repo:some-tag" , name .WeakValidation )
133
133
h .AssertNil (t , err )
134
134
135
- nameFromNewKey := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources a new key
135
+ nameFromNewKey , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources a new key
136
136
h .AssertNil (t , os .Setenv ("PACK_VOLUME_KEY" , "some-volume-key" ))
137
- nameFromEnvKey := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources key from env
137
+ nameFromEnvKey , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources key from env
138
138
h .AssertNotEq (t , nameFromNewKey .Name (), nameFromEnvKey .Name ())
139
139
})
140
140
})
@@ -158,15 +158,15 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
158
158
ref , err := name .ParseReference ("my/repo:some-tag" , name .WeakValidation )
159
159
h .AssertNil (t , err )
160
160
161
- nameFromNewKey := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources a new key
161
+ nameFromNewKey , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources a new key
162
162
163
163
cfgContents := `
164
164
[volume-keys]
165
165
"index.docker.io/my/repo:some-tag" = "SOME_VOLUME_KEY"
166
166
`
167
167
h .AssertNil (t , os .WriteFile (filepath .Join (tmpPackHome , "volume-keys.toml" ), []byte (cfgContents ), 0755 )) // overrides the key that was set
168
168
169
- nameFromConfigKey := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources key from config
169
+ nameFromConfigKey , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources key from config
170
170
h .AssertNotEq (t , nameFromNewKey .Name (), nameFromConfigKey .Name ())
171
171
})
172
172
})
@@ -176,11 +176,11 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
176
176
ref , err := name .ParseReference ("my/repo:some-tag" , name .WeakValidation )
177
177
h .AssertNil (t , err )
178
178
179
- nameFromNewKey := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources a new key
180
- nameFromConfigKey := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources same key from config
179
+ nameFromNewKey , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources a new key
180
+ nameFromConfigKey , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient ) // sources same key from config
181
181
h .AssertEq (t , nameFromNewKey .Name (), nameFromConfigKey .Name ())
182
182
183
- cfg , err := config .Read (filepath .Join (tmpPackHome , "volume-keys.toml" ))
183
+ cfg , err := config .ReadVolumeKeys (filepath .Join (tmpPackHome , "volume-keys.toml" ))
184
184
h .AssertNil (t , err )
185
185
h .AssertNotNil (t , cfg .VolumeKeys ["index.docker.io/my/repo:some-tag" ])
186
186
})
@@ -200,7 +200,7 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
200
200
ref , err := name .ParseReference ("my/repo" , name .WeakValidation )
201
201
h .AssertNil (t , err )
202
202
203
- subject := cache .NewVolumeCache (ref , cacheInfo , "some-suffix" , dockerClient )
203
+ subject , _ := cache .NewVolumeCache (ref , cacheInfo , "some-suffix" , dockerClient )
204
204
205
205
if volumeName != subject .Name () {
206
206
t .Fatalf ("Volume name '%s' should be same as the name specified '%s'" , subject .Name (), volumeName )
@@ -211,9 +211,9 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
211
211
ref , err := name .ParseReference ("my/repo" , name .WeakValidation )
212
212
h .AssertNil (t , err )
213
213
214
- subject := cache .NewVolumeCache (ref , cacheInfo , "some-suffix" , dockerClient )
214
+ subject , _ := cache .NewVolumeCache (ref , cacheInfo , "some-suffix" , dockerClient )
215
215
216
- expected := cache .NewVolumeCache (ref , cacheInfo , "some-suffix" , dockerClient )
216
+ expected , _ := cache .NewVolumeCache (ref , cacheInfo , "some-suffix" , dockerClient )
217
217
if subject .Name () != expected .Name () {
218
218
t .Fatalf ("The same repo name should result in the same volume" )
219
219
}
@@ -223,11 +223,11 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
223
223
ref , err := name .ParseReference ("registry.com/my/repo:other-tag" , name .WeakValidation )
224
224
h .AssertNil (t , err )
225
225
226
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
226
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
227
227
228
228
ref , err = name .ParseReference ("my/repo" , name .WeakValidation )
229
229
h .AssertNil (t , err )
230
- notExpected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
230
+ notExpected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
231
231
if subject .Name () == notExpected .Name () {
232
232
t .Fatalf ("Different image registries should result in different volumes" )
233
233
}
@@ -237,31 +237,31 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
237
237
ref , err := name .ParseReference ("my/repo:latest" , name .WeakValidation )
238
238
h .AssertNil (t , err )
239
239
240
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
240
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
241
241
242
242
ref , err = name .ParseReference ("my/repo" , name .WeakValidation )
243
243
h .AssertNil (t , err )
244
- expected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
244
+ expected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
245
245
h .AssertEq (t , subject .Name (), expected .Name ())
246
246
})
247
247
248
248
it ("resolves implied registry" , func () {
249
249
ref , err := name .ParseReference ("index.docker.io/my/repo" , name .WeakValidation )
250
250
h .AssertNil (t , err )
251
251
252
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
252
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
253
253
254
254
ref , err = name .ParseReference ("my/repo" , name .WeakValidation )
255
255
h .AssertNil (t , err )
256
- expected := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
256
+ expected , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
257
257
h .AssertEq (t , subject .Name (), expected .Name ())
258
258
})
259
259
260
260
it ("includes human readable information" , func () {
261
261
ref , err := name .ParseReference ("myregistryhost:5000/fedora/httpd:version1.0" , name .WeakValidation )
262
262
h .AssertNil (t , err )
263
263
264
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
264
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
265
265
266
266
h .AssertContains (t , subject .Name (), "fedora_httpd_version1.0" )
267
267
h .AssertTrue (t , names .RestrictedNamePattern .MatchString (subject .Name ()))
@@ -286,7 +286,7 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
286
286
ref , err := name .ParseReference (h .RandString (10 ), name .WeakValidation )
287
287
h .AssertNil (t , err )
288
288
289
- subject = cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
289
+ subject , _ = cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
290
290
volumeName = subject .Name ()
291
291
})
292
292
@@ -324,7 +324,7 @@ func testCache(t *testing.T, when spec.G, it spec.S) {
324
324
it ("returns the cache type" , func () {
325
325
ref , err := name .ParseReference ("my/repo" , name .WeakValidation )
326
326
h .AssertNil (t , err )
327
- subject := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
327
+ subject , _ := cache .NewVolumeCache (ref , cache.CacheInfo {}, "some-suffix" , dockerClient )
328
328
expected := cache .Volume
329
329
h .AssertEq (t , subject .Type (), expected )
330
330
})
0 commit comments