Find the
breaking point.

import http from 'k6/http';
import { check, sleep, group } from 'k6';
import { Trend } from 'k6/metrics';

const apiLatency = new Trend('api_latency');

export function setup() {
  const res = http.post('/auth/token', JSON.stringify({ id: __ENV.CLIENT_ID }));
  return { token: res.json().token };
}

export default function (data) {
  group('catalogue', () => {
    const res = http.get('/items?limit=20', {
      headers: { Authorization: `Bearer ${data.token}` },
    });
    apiLatency.add(res.duration_ms);
    check(res, {
      'status 200': (r) => r.status === 200,
      'has items': (r) => r.json().items.length > 0,
    });
  });
  sleep(Math.random() * 2 + 0.5);
}

// fires around every YAML request step
export function beforeRequest(req) {
  req.headers['X-Request-Id'] = crypto.uuidv4();
  return req;
}

# control plane (serves the web UI too)
$ loadr controller --bind 0.0.0.0:7625 --ui-bind 0.0.0.0:6464

# on every load generator
$ loadr agent --join ctrl-host:7625 --name agent-$(hostname)

# submit: 600 req/s split across the whole fleet
$ loadr run --controller ctrl-host:6464 test.yaml

# or bring up controller + 3 agents + Prometheus + Grafana:
$ docker compose -f deploy/docker-compose.yml up
# k8s: helm install loadr deploy/helm/loadr --set agents.replicas=10

# JMeter: thread groups, samplers, timers, assertions,
# extractors, CSV configs, transaction controllers...
$ loadr convert existing-plan.jmx -o converted.yaml
warning: [ConstantThroughputTimer] mapped to scenario pacing (per-minute → per-second)

# k6: options, scenarios, stages, thresholds, http.*, checks, sleep, group
$ loadr convert k6-script.js -o converted.yaml

# converted output always validates
$ loadr validate converted.yaml
✓ converted.yaml is valid (3 scenarios, 14 requests)