Function TestRateLimiterMemoryStore_RaceDetection

middleware/rate_limiter_test.go:584–612

TestRateLimiterMemoryStore_RaceDetection verifies no data races with high concurrency Run with: go test -race ./middleware -run TestRateLimiterMemoryStore_RaceDetection

(t *testing.T)

// TestRateLimiterMemoryStore_RaceDetection verifies no data races with high concurrency
// Run with: go test -race ./middleware -run TestRateLimiterMemoryStore_RaceDetection
func TestRateLimiterMemoryStore_RaceDetection(t *testing.T) {
	t.Parallel()

	store := NewRateLimiterMemoryStoreWithConfig(RateLimiterMemoryStoreConfig{
		Rate:      100,
		Burst:     200,
		ExpiresIn: 1 * time.Second,
	})

	const goroutines = 100
	const requestsPerGoroutine = 100

	var wg sync.WaitGroup
	identifiers := []string{"user1", "user2", "user3", "user4", "user5"}

	for i := range goroutines {
		wg.Add(1)
		go func(routineID int) {
			defer wg.Done()
			for range requestsPerGoroutine {
				identifier := identifiers[routineID%len(identifiers)]
				_, err := store.Allow(identifier)
				assert.NoError(t, err)
			}
		}(i)
	}

	wg.Wait()
}

// TestRateLimiterMemoryStore_TimeOrdering verifies time ordering consistency in rate limiting decisions
func TestRateLimiterMemoryStore_TimeOrdering(t *testing.T) {