fix TestWatcher

Signed-off-by: Ryan Leung <[email protected]>
rleungx · Nov 14, 2024 · 88de955 · 88de955
1 parent 40ae26c
commit 88de955
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/encryption/key_manager_test.go b/pkg/encryption/key_manager_test.go
@@ -329,8 +329,7 @@ func TestWatcher(t *testing.T) {
 	// Listen on watcher event
 	reloadEvent := make(chan struct{}, 10)
 	helper.eventAfterReloadByWatcher = func() {
-		var e struct{}
-		reloadEvent <- e
+		reloadEvent <- struct{}{}
 	}
 	// Use default config.
 	config := &Config{}
@@ -339,6 +338,7 @@ func TestWatcher(t *testing.T) {
 	// Create the key manager.
 	m, err := newKeyManagerImpl(client, config, helper)
 	re.NoError(err)
+	m.mu.keysRevision = 0
 	go m.StartBackgroundLoop(ctx)
 	_, err = m.GetKey(123)
 	re.Error(err)