Function run_full_benchmarks

benchmarks/dirty_streaming.py:692–725

Run full benchmark suite including stress tests.

()

async def run_full_benchmarks():
    """Run full benchmark suite including stress tests."""
    results = BenchmarkResults()

    print("Running full benchmark suite...")

    # Throughput tests with different chunk sizes
    for chunk_size in [1, 64, 1024, 65536]:
        await benchmark_worker_streaming_throughput(
            results, chunk_size=chunk_size, num_chunks=1000
        )

    # Arbiter forwarding
    await benchmark_arbiter_forwarding(results, num_chunks=10000)

    # Latency
    await benchmark_streaming_latency(results, iterations=100)

    # Concurrent streams
    await benchmark_concurrent_streams(results, num_streams=10, chunks_per_stream=100)
    await benchmark_concurrent_streams(results, num_streams=50, chunks_per_stream=100)

    # Memory stability
    await benchmark_memory_stability(results, iterations=20, chunks=1000)

    # Async client streaming benchmarks
    for chunk_size in [64, 1024, 65536]:
        await benchmark_async_client_streaming(results, chunk_size=chunk_size, num_chunks=1000)
        await benchmark_sync_client_streaming(results, chunk_size=chunk_size, num_chunks=1000)

    # Comparison benchmark
    await benchmark_async_vs_sync_client_streaming(results, chunk_size=1024, num_chunks=5000)

    return results


def main():