wip

Author: pregnantboy

tools/load-tests/.env-example

@@ -0,0 +1 @@
+POSTGRES_TILES_URL=postgres://postgres:postgres@localhost:5432/tiles

tools/load-tests/README.md

@@ -6,6 +6,23 @@
 then
 `k6 run formsg.js`
 
+### Build k6 with extensions
+Since we are using k6 plugins, we need to use xk6 to build k6 with extensions.
+
+We are using the following extensions:
+- postgres
+- dotenv
+- dashboard
+
+```
+docker run --rm -it -e GOOS=darwin -u "$(id -u):$(id -g)" -v "${PWD}:/xk6" \
+  grafana/xk6 build \
+  --with github.com/grafana/xk6-sql@latest \
+  --with github.com/grafana/xk6-sql-driver-postgres@latest \
+  --with github.com/grafana/xk6-dashboard@latest\
+  --with github.com/szkiba/xk6-dotenv@latest
+```
+
 ### To run with dashboard
 
 `./k6 run --out dashboard=open webhook.js`

tools/load-tests/k6

@@ -6,6 +6,6 @@
   "author": "",
   "license": "ISC",
   "devDependencies": {
-    "@types/k6": "^0.43.2"
+    "@types/k6": "^1.0.2"
   }
 }

tools/load-tests/package-lock.json

@@ -0,0 +1,42 @@
+/* eslint-disable no-undef */
+import exec from 'k6/execution'
+import sql from 'k6/x/sql'
+import driver from 'k6/x/sql/driver/postgres'
+
+// Test configuration
+export const options = {
+  discardResponseBodies: true,
+  scenarios: {
+    contacts: {
+      executor: 'constant-arrival-rate',
+
+      duration: '5m',
+
+      rate: 100,
+
+      // It should start `rate` iterations per second
+      timeUnit: '10s',
+
+      // It should preallocate 2 VUs before starting the test
+      preAllocatedVUs: 100,
+
+      // It is allowed to spin up to 50 maximum VUs to sustain the defined
+      // constant arrival rate.
+    },
+  },
+}
+
+export default function () {
+  const db = sql.open(driver, __ENV.POSTGRES_TILES_URL)
+  const i = Math.floor(Math.random() * 30)
+  db.exec(`
+    SELECT * FROM "public"."load_test_table_${
+      exec.vu.idInInstance
+    }" ORDER BY "rowId" LIMIT 10000 OFFSET ${i * 10000};
+  `)
+  console.log(
+    `read ${i * 10000} rows in load_test_table_${exec.vu.idInInstance}`,
+  )
+
+  db.close()
+}

tools/load-tests/package.json

@@ -0,0 +1,56 @@
+/* eslint-disable no-undef */
+import { check } from 'k6'
+import exec from 'k6/execution'
+import sql from 'k6/x/sql'
+import driver from 'k6/x/sql/driver/postgres'
+
+// Test configuration
+export const options = {
+  discardResponseBodies: true,
+  scenarios: {
+    contacts: {
+      executor: 'constant-arrival-rate',
+
+      duration: '5m',
+
+      rate: 50,
+
+      // It should start `rate` iterations per second
+      timeUnit: '1s',
+
+      // It should preallocate 2 VUs before starting the test
+      preAllocatedVUs: 100,
+
+      // It is allowed to spin up to 50 maximum VUs to sustain the defined
+      // constant arrival rate.
+      maxVUs: 100,
+    },
+  },
+}
+
+const generatedRows = Array.from({ length: 1000 }, (_, i) => {
+  return Array.from({ length: 10 }, (_, j) => {
+    return `'row${i}-col${j}'`
+  }).join(',')
+})
+
+export default function () {
+  const db = sql.open(driver, __ENV.POSTGRES_TILES_URL)
+  const result = db.exec(`
+    INSERT INTO "public"."load_test_table_${
+      exec.vu.idInInstance
+    }" ("rowId", "column0", "column1", "column2", "column3", "column4", "column5", "column6", "column7", "column8", "column9") VALUES ${generatedRows
+    .map((row) => `('${crypto.randomUUID()}', ${row})`)
+    .join(',\n')};
+  `)
+  // const result = db.exec(`
+  //   SELECT 1 FROM "public"."load_test_table_${exec.vu.idInInstance}";
+  // `)
+  check(result, 'is added', (r) => r.rowsAffected() === 1000)
+  console.log(
+    `added ${result.rowsAffected()} rows in load_test_table_${
+      exec.vu.idInInstance
+    }`,
+  )
+  db.close()
+}

tools/load-tests/tiles/bulk_read.js

@@ -0,0 +1,49 @@
+/* eslint-disable no-undef */
+import { check } from 'k6'
+import exec from 'k6/execution'
+import sql from 'k6/x/sql'
+import driver from 'k6/x/sql/driver/postgres'
+
+// Test configuration
+export const options = {
+  discardResponseBodies: true,
+  scenarios: {
+    contacts: {
+      executor: 'constant-arrival-rate',
+
+      duration: '10m',
+
+      rate: 20,
+
+      // It should start `rate` iterations per second
+      timeUnit: '1s',
+
+      // It should preallocate 2 VUs before starting the test
+      preAllocatedVUs: 100,
+
+      // It is allowed to spin up to 50 maximum VUs to sustain the defined
+      // constant arrival rate.
+      maxVUs: 100,
+    },
+  },
+}
+
+export default function () {
+  const db = sql.open(driver, __ENV.POSTGRES_TILES_URL)
+
+  const result = db.exec(`
+    SELECT * FROM "public"."load_test_table_1" WHERE "column1" = 'row${Math.floor(
+      Math.random() * 1000,
+    )}-col1';;
+  `)
+  // const result = db.exec(`
+  //   SELECT 1 FROM "public"."load_test_table_${exec.vu.idInInstance}";
+  // `)
+  check(result, 'is added', (r) => r.rowsAffected() === 1)
+  console.log(
+    `selected ${result.rowsAffected()} row from load_test_table_${
+      exec.vu.idInInstance
+    }`,
+  )
+  db.close()
+}

tools/load-tests/tiles/bulk_write.js

@@ -0,0 +1,27 @@
+/* eslint-disable no-undef */
+import exec from 'k6/execution'
+import sql from 'k6/x/sql'
+import driver from 'k6/x/sql/driver/postgres'
+
+// Test configuration
+export const options = {
+  iterations: 1000,
+  vus: 1,
+}
+
+export default function () {
+  const db = sql.open(driver, __ENV.POSTGRES_TILES_URL)
+  const tableId = exec.vu.iterationInInstance
+
+  db.exec(`
+      CREATE TABLE IF NOT EXISTS "public"."load_test_table_${tableId}" (
+      "rowId" varchar(255) NOT NULL,
+      "createdAt" timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP,
+      "updatedAt" timestamptz NOT NULL DEFAULT CURRENT_TIMESTAMP,
+      ${Array.from({ length: 10 }, (_, i) => `"column${i}" text`).join(',\n')},
+      PRIMARY KEY ("rowId")
+  );
+    `)
+  console.log(`table created: load_test_table_${tableId}`)
+  db.close()
+}

tools/load-tests/tiles/read_action.js

@@ -0,0 +1,16 @@
+/* eslint-disable no-undef */
+import sql from 'k6/x/sql'
+import driver from 'k6/x/sql/driver/postgres'
+
+// Test configuration
+export const options = {
+  iterations: 1,
+  vus: 1,
+}
+
+export default function () {
+  const db = sql.open(driver, __ENV.POSTGRES_TILES_URL)
+  const result = db.exec(`SELECT 1 as connection_test`)
+  console.log(result.rowsAffected())
+  db.close()
+}

tools/load-tests/tiles/seed_table.js

@@ -0,0 +1,44 @@
+/* eslint-disable no-undef */
+import { check } from 'k6'
+import exec from 'k6/execution'
+import sql from 'k6/x/sql'
+import driver from 'k6/x/sql/driver/postgres'
+
+// Test configuration
+export const options = {
+  discardResponseBodies: true,
+  scenarios: {
+    contacts: {
+      executor: 'constant-arrival-rate',
+
+      duration: '10m',
+
+      rate: 50,
+
+      // It should start `rate` iterations per second
+      timeUnit: '1s',
+
+      // It should preallocate 2 VUs before starting the test
+      preAllocatedVUs: 100,
+
+      // It is allowed to spin up to 50 maximum VUs to sustain the defined
+      // constant arrival rate.
+      maxVUs: 100,
+    },
+  },
+}
+
+export default function () {
+  const db = sql.open(driver, __ENV.POSTGRES_TILES_URL)
+  const result = db.exec(`
+    UPDATE "public"."load_test_table_${exec.vu.idInInstance}" SET "column2" = 'updated' WHERE "rowId" = 'to update';
+  `)
+
+  check(result, 'is added', (r) => r.rowsAffected() === 1)
+  console.log(
+    `added ${result.rowsAffected()} rows in load_test_table_${
+      exec.vu.idInInstance
+    }`,
+  )
+  db.close()
+}

tools/load-tests/tiles/test.js

@@ -0,0 +1,56 @@
+/* eslint-disable no-undef */
+import { check } from 'k6'
+import exec from 'k6/execution'
+import sql from 'k6/x/sql'
+import driver from 'k6/x/sql/driver/postgres'
+
+// Test configuration
+export const options = {
+  discardResponseBodies: true,
+  scenarios: {
+    contacts: {
+      executor: 'constant-arrival-rate',
+
+      duration: '10m',
+
+      rate: 50,
+
+      // It should start `rate` iterations per second
+      timeUnit: '1s',
+
+      // It should preallocate 2 VUs before starting the test
+      preAllocatedVUs: 100,
+
+      // It is allowed to spin up to 50 maximum VUs to sustain the defined
+      // constant arrival rate.
+      maxVUs: 100,
+    },
+  },
+}
+
+const generatedRows = Array.from({ length: 1 }, (_, i) => {
+  return Array.from({ length: 10 }, (_, j) => {
+    return `'row${i}-col${j}'`
+  }).join(',')
+})
+
+export default function () {
+  const db = sql.open(driver, __ENV.POSTGRES_TILES_URL)
+  const result = db.exec(`
+    INSERT INTO "public"."load_test_table_${
+      exec.vu.idInInstance
+    }" ("rowId", "column0", "column1", "column2", "column3", "column4", "column5", "column6", "column7", "column8", "column9") VALUES ${generatedRows
+    .map((row) => `('${crypto.randomUUID()}', ${row})`)
+    .join(',\n')};
+  `)
+  // const result = db.exec(`
+  //   SELECT 1 FROM "public"."load_test_table_${exec.vu.idInInstance}";
+  // `)
+  check(result, 'is added', (r) => r.rowsAffected() === 1)
+  console.log(
+    `added ${result.rowsAffected()} rows in load_test_table_${
+      exec.vu.idInInstance
+    }`,
+  )
+  db.close()
+}