xk6sip

README

xk6-sip

k6 extension k6/x/sip for load testing PBXs and SIP servers with scripted subscribers: each VU owns real SIP devices that register, call each other through the system under test and check what arrives on the other side.

Status: signalling only (REGISTER, INVITE/CANCEL/BYE, digest auth). RTP is not implemented yet; SDP carries a placeholder media port.

Build and run

xk6 build v2.3.0 --with github.com/Dmitry-Fedotov-Dev/xk6-sip=. --output bin/k6
go build -o bin/testpbx ./cmd/testpbx

bin/testpbx -addr 127.0.0.1:5070 -users 200 -csv examples/subscribers.csv
bin/k6 run examples/call.js

Timings below a millisecond are only reliable on Linux: Go's clock on Windows ticks in ~0.5 ms steps.

Script API

import sip from 'k6/x/sip';

sip.options({ registerRate: 50, expectTimeout: '30s' }); // init context, optional

// No network in init; REGISTER is sent on first use and refreshed.
// Unknown string fields (ext, onk, gw_num, ...) are the device's numbers.
const ua1 = new sip.Device({ device: 'phone1', registrar: 'sip:pbx:5060',
  user: 'a@domain', pass: 'secret', expires: 180, ext: '701' });

export default function () {
  const out = ua1.call({ callee: ua2, aon: 'ext' });   // returns at once
  const inc = ua2.expectCall({ caller: ua1, aon: 'ext', timeout: '5s' }); // Call or false
  inc.accept();
  out.expectConnected();        // true/false
  inc.hangup();                 // CANCEL, reject or BYE depending on state
  out.expectDisconnected();
}

export function teardown() { sip.shutdown(); } // unregister everything

Device: call, expectCall, register, isRegistered, identity(key), destroy, id. Call: accept, reject(code?, reason?), hangup, expectRinging, expectConnected, expectDisconnected (optional timeout), state, status, remote, howCompleted, trace (SIP ladder), callId.

Only expect* methods wait, so one VU can drive both ends of a call.

Metrics

metric	type	tags
sip_requests	counter	method, status
sip_request_duration	trend	method, status
sip_failed_requests	rate	method (401/407 challenges are not failures)
sip_call_setup_time	trend	INVITE → 200
sip_post_dial_delay	trend	INVITE → first 18x
sip_call_success	rate	status
sip_call_duration	trend	ended_by
sip_invite_delivery_time	trend	caller's INVITE → callee receives it
sip_registrations	counter
sip_expect_failed	counter	expect

sip.options({ deviceTag: true }) adds a device tag to all of them.

Layout

• engine/ – SIP core, independent of k6 (sipgo transactions + own dialog layer)
• testpbx/, cmd/testpbx – minimal registrar/B2BUA for tests and examples
• repo root – the k6 adapter

Documentation

Overview

Package xk6sip is the k6 extension k6/x/sip. It exposes the SIP engine to k6 scripts and turns engine events into k6 metrics.

Index

• type ModuleInstance
  • func (mi *ModuleInstance) Exports() modules.Exports
• type RootModule
  • func New() *RootModule
  • func (r *RootModule) NewModuleInstance(vu modules.VU) modules.Instance

Types

type ModuleInstance

type ModuleInstance struct {
	// contains filtered or unexported fields
}

func (*ModuleInstance) Exports

func (mi *ModuleInstance) Exports() modules.Exports

type RootModule

type RootModule struct {
	// contains filtered or unexported fields
}

RootModule is shared by all VUs; it owns the single SIP engine of the process so that engine-wide limits (register rate) apply to the whole test.

func New

func New() *RootModule

func (*RootModule) NewModuleInstance

func (r *RootModule) NewModuleInstance(vu modules.VU) modules.Instance