add status deleting of volumesnapshot
Signed-off-by: zhangmin <arminzhang@yunify.com>
This commit is contained in:
@@ -28,6 +28,7 @@ import (
|
||||
const (
|
||||
statusCreating = "creating"
|
||||
statusReady = "ready"
|
||||
statusDeleting = "deleting"
|
||||
|
||||
volumeSnapshotClassName = "volumeSnapshotClassName"
|
||||
persistentVolumeClaimName = "persistentVolumeClaimName"
|
||||
@@ -96,5 +97,8 @@ func snapshotStatus(item *v1beta1.VolumeSnapshot) string {
|
||||
if item != nil && item.Status != nil && item.Status.ReadyToUse != nil && *item.Status.ReadyToUse {
|
||||
status = statusReady
|
||||
}
|
||||
if item != nil && item.DeletionTimestamp != nil{
|
||||
status = statusDeleting
|
||||
}
|
||||
return status
|
||||
}
|
||||
|
||||
@@ -208,13 +208,17 @@ func TestListVolumeSnapshot(t *testing.T) {
|
||||
}
|
||||
Expect(snapshotStatus(snapshot)).To(Equal(statusReady))
|
||||
})
|
||||
|
||||
It("snapshot.DeletionTimestamp != nil", func() {
|
||||
deleteTime := v1.Now()
|
||||
snapshot.DeletionTimestamp = &deleteTime
|
||||
defer func() {
|
||||
snapshot.DeletionTimestamp = nil
|
||||
}()
|
||||
Expect(snapshotStatus(snapshot)).To(Equal(statusDeleting))
|
||||
})
|
||||
|
||||
})
|
||||
|
||||
RunSpecs(t, "volume snapshot getter list")
|
||||
}
|
||||
|
||||
//func TestVolumeSnapshotStatus( t *testing.T) {
|
||||
// RegisterFailHandler(Fail)
|
||||
//
|
||||
// RunSpecs(t, "volume snapshot status")
|
||||
//}
|
||||
|
||||
Reference in New Issue
Block a user