Function TestCachedScanner_ConcurrentAccess

pkg/util/users/cache_test.go:113–151

(t *testing.T)

}

func TestCachedScanner_ConcurrentAccess(t *testing.T) {
	t.Parallel()

	ctx := context.Background()
	reg := prometheus.NewRegistry()
	scanner := &mockScanner{
		active:   []string{"user-1"},
		deleting: []string{"user-2"},
		deleted:  []string{"user-3"},
	}

	cachedScanner := newCachedScanner(scanner, UsersScannerConfig{
		CacheTTL: 1 * time.Hour,
	}, reg)

	// Run multiple concurrent scans
	const goroutines = 10
	done := make(chan struct{})

	for range goroutines {
		go func() {
			defer func() { done <- struct{}{} }()

			active, deleting, deleted, err := cachedScanner.ScanUsers(ctx)
			require.NoError(t, err)
			assert.Equal(t, scanner.active, active)
			assert.Equal(t, scanner.deleting, deleting)
			assert.Equal(t, scanner.deleted, deleted)
		}()
	}

	// Wait for all goroutines to complete
	for range goroutines {
		<-done
	}

	// Verify that the underlying scanner was called only once
	assert.Equal(t, 1, scanner.calls)
}