Add R2 parallel get benchmark with timing logs

test/r2-bench/worker.js

@@ -0,0 +1,88 @@
+// Pure JS worker to test R2 parallel vs sequential get performance.
+// Run with: cd test/r2-bench && npx wrangler dev
+
+const COUNT = 1024;
+const CHUNK_SIZE = 32;
+
+async function seed(bucket) {
+  const existing = await bucket.head(`bench/key-0`);
+  if (existing) return;
+  for (let i = 0; i < COUNT; i++) {
+    await bucket.put(`bench/key-${i}`, `value-${i}`);
+  }
+}
+
+async function sequential(bucket) {
+  const start = Date.now();
+  const values = [];
+  for (let i = 0; i < COUNT; i++) {
+    const obj = await bucket.get(`bench/key-${i}`);
+    values.push(await obj.text());
+  }
+  return { mode: "sequential", count: values.length, elapsed_ms: Date.now() - start };
+}
+
+async function parallel(bucket) {
+  const start = Date.now();
+  const promises = [];
+  for (let i = 0; i < COUNT; i++) {
+    promises.push(
+      bucket.get(`bench/key-${i}`).then((obj) => obj.text())
+    );
+  }
+  const values = await Promise.all(promises);
+  return { mode: "parallel", count: values.length, elapsed_ms: Date.now() - start };
+}
+
+async function chunked(bucket) {
+  const start = Date.now();
+  const values = [];
+  for (let offset = 0; offset < COUNT; offset += CHUNK_SIZE) {
+    const chunk = [];
+    for (let i = offset; i < Math.min(offset + CHUNK_SIZE, COUNT); i++) {
+      chunk.push(
+        bucket.get(`bench/key-${i}`).then((obj) => obj.text())
+      );
+    }
+    values.push(...await Promise.all(chunk));
+  }
+  return { mode: "chunked", count: values.length, elapsed_ms: Date.now() - start };
+}
+
+export default {
+  async fetch(request, env) {
+    const url = new URL(request.url);
+    const bucket = env.BUCKET;
+
+    if (url.pathname === "/seed") {
+      await seed(bucket);
+      return Response.json({ seeded: COUNT });
+    }
+
+    if (url.pathname === "/sequential") {
+      await seed(bucket);
+      return Response.json(await sequential(bucket));
+    }
+
+    if (url.pathname === "/parallel") {
+      await seed(bucket);
+      return Response.json(await parallel(bucket));
+    }
+
+    if (url.pathname === "/chunked") {
+      await seed(bucket);
+      return Response.json(await chunked(bucket));
+    }
+
+    if (url.pathname === "/all") {
+      await seed(bucket);
+      return Response.json({
+        sequential: await sequential(bucket),
+        parallel: await parallel(bucket),
+        chunked: await chunked(bucket),
+      });
+    }
+
+    return new Response("GET /sequential, /parallel, /chunked, or /all", { status: 404 });
+  },
+};

test/r2-bench/wrangler.toml

@@ -0,0 +1,8 @@
+name = "r2-bench"
+main = "worker.js"
+compatibility_date = "2025-09-23"
+
+[[r2_buckets]]
+binding = "BUCKET"
+bucket_name = "bench-bucket"
+preview_bucket_name = "bench-bucket"