From 5630f53dd5b6d369c713aad0a5d3a3b37c187f7e Mon Sep 17 00:00:00 2001 From: Matt Toohey Date: Thu, 20 Jun 2024 11:47:12 +1000 Subject: [PATCH] clean up test --- common/configuration/asm_test.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/common/configuration/asm_test.go b/common/configuration/asm_test.go index f436cd8c1b..754d49adde 100644 --- a/common/configuration/asm_test.go +++ b/common/configuration/asm_test.go @@ -39,7 +39,7 @@ func localstack(ctx context.Context, t *testing.T) (*ASM, *asmLeader) { return asm, leader } -func waitForCacheToProcessUpdates(l *asmLeader) { // nolint:unused +func waitForUpdatesToProcess(l *asmLeader) { l.topicWaitGroup.Wait() } @@ -60,7 +60,7 @@ func TestASMWorkflow(t *testing.T) { assert.Equal(t, items, []Entry{}) err = manager.Set(ctx, "asm", ref, mySecret) - waitForCacheToProcessUpdates(leader) + waitForUpdatesToProcess(leader) assert.NoError(t, err) items, err = manager.List(ctx) @@ -73,7 +73,7 @@ func TestASMWorkflow(t *testing.T) { // Set again to make sure it updates. mySecret = []byte("hunter1") err = manager.Set(ctx, "asm", ref, mySecret) - waitForCacheToProcessUpdates(leader) + waitForUpdatesToProcess(leader) assert.NoError(t, err) err = manager.Get(ctx, ref, &gotSecret) @@ -81,7 +81,7 @@ func TestASMWorkflow(t *testing.T) { assert.Equal(t, gotSecret, mySecret) err = manager.Unset(ctx, "asm", ref) - waitForCacheToProcessUpdates(leader) + waitForUpdatesToProcess(leader) assert.NoError(t, err) items, err = manager.List(ctx) @@ -133,7 +133,7 @@ func TestASMPagination(t *testing.T) { err := manager.Unset(ctx, "asm", ref) assert.NoError(t, err) } - waitForCacheToProcessUpdates(leader) + waitForUpdatesToProcess(leader) // Make sure they are all gone items, err = manager.List(ctx)