@@ -26,6 +26,7 @@ import (
26
26
"github.com/stretchr/testify/assert"
27
27
28
28
"k8s.io/apimachinery/pkg/types"
29
+ "k8s.io/utils/pointer"
29
30
)
30
31
31
32
func TestCommonAttachDisk (t * testing.T ) {
@@ -243,3 +244,38 @@ func TestDisksAreAttached(t *testing.T) {
243
244
assert .Equal (t , test .expectedErr , err != nil , "TestCase[%d]: %s" , i , test .desc )
244
245
}
245
246
}
247
+
248
+ func TestFilteredDetatchingDisks (t * testing.T ) {
249
+
250
+ disks := []compute.DataDisk {
251
+ {
252
+ Name : pointer .StringPtr ("DiskName1" ),
253
+ ToBeDetached : pointer .BoolPtr (false ),
254
+ ManagedDisk : & compute.ManagedDiskParameters {
255
+ ID : pointer .StringPtr ("ManagedID" ),
256
+ },
257
+ },
258
+ {
259
+ Name : pointer .StringPtr ("DiskName2" ),
260
+ ToBeDetached : pointer .BoolPtr (true ),
261
+ },
262
+ {
263
+ Name : pointer .StringPtr ("DiskName3" ),
264
+ ToBeDetached : nil ,
265
+ },
266
+ {
267
+ Name : pointer .StringPtr ("DiskName4" ),
268
+ ToBeDetached : nil ,
269
+ },
270
+ }
271
+
272
+ filteredDisks := filterDetachingDisks (disks )
273
+ assert .Equal (t , 3 , len (filteredDisks ))
274
+ assert .Equal (t , "DiskName1" , * filteredDisks [0 ].Name )
275
+ assert .Equal (t , "ManagedID" , * filteredDisks [0 ].ManagedDisk .ID )
276
+ assert .Equal (t , "DiskName3" , * filteredDisks [1 ].Name )
277
+
278
+ disks = []compute.DataDisk {}
279
+ filteredDisks = filterDetachingDisks (disks )
280
+ assert .Equal (t , 0 , len (filteredDisks ))
281
+ }
0 commit comments