@@ -78,33 +78,37 @@ var _ = AfterSuite(func() {
78
78
79
79
var _ = Describe ("Operator Backup" , Label ("e2e" , "pr" ), func () {
80
80
When ("a cluster has backups enabled and then restored" , func () {
81
- var keyValues []fixtures.KeyValue
82
- var prefix byte = 'a'
83
81
var backup * fixtures.FdbBackup
84
- var restorableVersion uint64
85
82
86
83
BeforeEach (func () {
87
84
log .Println ("creating backup for cluster" )
88
85
backup = factory .CreateBackupForCluster (fdbCluster )
89
- keyValues = fdbCluster .GenerateRandomValues (10 , prefix )
90
- fdbCluster .WriteKeyValues (keyValues )
91
- restorableVersion = backup .WaitForRestorableVersion (fdbCluster .GetClusterVersion ())
92
- backup .Stop ()
93
86
})
94
87
95
88
AfterEach (func () {
89
+ backup .Stop ()
96
90
log .Println ("deleting backup" )
97
91
factory .Delete (backup .GetBackupPod ())
98
92
backup = nil
99
93
})
100
94
101
95
It ("should restore the cluster successfully" , func () {
96
+ var prefix byte = 'a'
97
+ var keyValues []fixtures.KeyValue = fdbCluster .GenerateRandomValues (10 , prefix )
98
+ fdbCluster .WriteKeyValues (keyValues )
99
+ backup .WaitForRestorableVersion (fdbCluster .GetClusterVersion ())
100
+ backup .Stop ()
102
101
fdbCluster .ClearRange ([]byte {prefix }, 60 )
103
102
factory .CreateRestoreForCluster (backup , nil )
104
103
Expect (fdbCluster .GetRange ([]byte {prefix }, 25 , 60 )).Should (Equal (keyValues ))
105
104
})
106
105
107
106
It ("should restore the cluster successfully with a restorable version" , func () {
107
+ var prefix byte = 'a'
108
+ var keyValues []fixtures.KeyValue = fdbCluster .GenerateRandomValues (10 , prefix )
109
+ fdbCluster .WriteKeyValues (keyValues )
110
+ var restorableVersion uint64 = backup .WaitForRestorableVersion (fdbCluster .GetClusterVersion ())
111
+ backup .Stop ()
108
112
fdbCluster .ClearRange ([]byte {prefix }, 60 )
109
113
factory .CreateRestoreForCluster (backup , & restorableVersion )
110
114
Expect (fdbCluster .GetRange ([]byte {prefix }, 25 , 60 )).Should (Equal (keyValues ))
0 commit comments