2021-03-10 06:47:13 +13:00
|
|
|
// k6 run tests/benchmarks/ws.js
|
|
|
|
|
|
|
|
import { URL } from 'https://jslib.k6.io/url/1.0.0/index.js';
|
|
|
|
import ws from 'k6/ws';
|
|
|
|
import { check } from 'k6';
|
|
|
|
|
|
|
|
export let options = {
|
|
|
|
stages: [
|
|
|
|
{ duration: '20s', target: 10 },
|
|
|
|
{ duration: '20s', target: 100 },
|
|
|
|
{ duration: '20s', target: 0 },
|
2021-03-10 19:52:10 +13:00
|
|
|
],
|
2021-03-10 06:47:13 +13:00
|
|
|
}
|
|
|
|
|
|
|
|
export default function () {
|
|
|
|
const url = new URL('ws://localhost/v1/realtime');
|
2021-03-10 19:52:10 +13:00
|
|
|
url.searchParams.append('project', '60479391b1c3f');
|
2021-03-10 06:47:13 +13:00
|
|
|
url.searchParams.append('channels[]', 'files');
|
2021-03-10 19:52:10 +13:00
|
|
|
|
2021-03-10 06:47:13 +13:00
|
|
|
const res = ws.connect(url.toString(), function (socket) {
|
|
|
|
socket.on('open', () => {
|
|
|
|
console.log('connected')
|
|
|
|
});
|
2021-03-10 19:52:10 +13:00
|
|
|
|
2021-03-10 06:47:13 +13:00
|
|
|
socket.on('message', (data) => {
|
|
|
|
console.log('Message received: ', data)
|
|
|
|
});
|
2021-03-10 19:52:10 +13:00
|
|
|
|
2021-03-10 06:47:13 +13:00
|
|
|
socket.on('close', () => console.log('disconnected'));
|
2021-03-10 19:52:10 +13:00
|
|
|
|
2021-03-10 06:47:13 +13:00
|
|
|
socket.setTimeout(function () {
|
|
|
|
console.log('2 seconds passed, closing the socket');
|
|
|
|
socket.close();
|
2021-03-10 19:52:10 +13:00
|
|
|
}, 2000);
|
2021-03-10 06:47:13 +13:00
|
|
|
});
|
2021-03-10 19:52:10 +13:00
|
|
|
|
2021-03-10 06:47:13 +13:00
|
|
|
check(res, { 'status is 101': (r) => r && r.status === 101 });
|
|
|
|
}
|