Function BenchmarkMixedWorkload

internal/engines/bulk_benchmark_test.go:389–468

BenchmarkMixedWorkload tests mixed workload with different request patterns

(b *testing.B)

// BenchmarkMixedWorkload tests mixed workload with different request patterns
func BenchmarkMixedWorkload(b *testing.B) {
	ctx := context.Background()
	checker := &MockChecker{}

	config := BulkCheckerConfig{
		ConcurrencyLimit: 75,
		BufferSize:       75000,
	}

	callback := func(id, ct string) {}

	b.ResetTimer()
	b.ReportAllocs()

	for b.Loop() {
		bc, err := NewBulkChecker(ctx, checker, BulkCheckerTypeEntity, callback, config)
		if err != nil {
			b.Fatal(err)
		}

		publisher := NewBulkEntityPublisher(ctx, &base.PermissionLookupEntityRequest{
			TenantId:   "test",
			Metadata:   &base.PermissionLookupEntityRequestMetadata{},
			EntityType: "document",
			Permission: "read",
			Subject:    &base.Subject{Id: "user1"},
		}, bc)

		// Mixed workload: some sequential, some concurrent, some burst
		var wg sync.WaitGroup

		// Sequential requests
		for j := 0; j < 10000; j++ {
			publisher.Publish(
				&base.Entity{Id: fmt.Sprintf("seq_%d", j)},
				&base.PermissionCheckRequestMetadata{},
				&base.Context{},
				base.CheckResult_CHECK_RESULT_UNSPECIFIED,
			)
		}

		// Concurrent requests
		for g := 0; g < 25; g++ {
			wg.Add(1)
			go func(goroutineID int) {
				defer wg.Done()
				for j := 0; j < 2000; j++ {
					publisher.Publish(
						&base.Entity{Id: fmt.Sprintf("concurrent_%d_%d", goroutineID, j)},
						&base.PermissionCheckRequestMetadata{},
						&base.Context{},
						base.CheckResult_CHECK_RESULT_UNSPECIFIED,
					)
				}
			}(g)
		}

		// Burst requests