Function benchmark

example/deployment/kubernetes/benchmark.py:19–23

(clients, messages)

async def benchmark(clients, messages):
    await asyncio.wait([
        asyncio.create_task(run(client_id, messages))
        for client_id in range(clients)
    ])


if __name__ == "__main__":