wt

README

xk6-webtransport

k6 extension to k6 extension to use the WebTransport protocol. Implemented using the xk6 system and webtransport-go.

Supports:

• bidirectional streams
• datagrams

Work in progress

This project is a work in progress. Feedback and contributions are welcome!

Contents

• Build
• Supported features
• Usage example
• Metrics

Build

To build a k6 binary with this extension, first ensure you have the prerequisites:

• Go
• Git

Then:

• Install xk6:

go install go.k6.io/xk6/cmd/xk6@latest

• Build the binary:

xk6 build --with github.com/kelseyaubrecht/xk6-webtransport@latest

Supported features

• Bidirectional stream
  • Write
  • ReadAll
  • ReadFull
  • ReadAtLeast

Usage example

An example of using the extension to create a bidirection stream. More in examples.

import wt from "k6/x/webtransport";

export default function () {
  const url = "https://localhost:443/webtransport";
  wt.connect(url);

  let data = [0, 1, 2, 3, 4];
  wt.write(data);

  const response = wt.readAll();
  // handle response

  wt.close();
}

Metrics

Metric	Type	Description
webtransport_read_bytes	counter	Total bytes read
webtransport_read_count	counter	Total read count
webtransport_read_size	trend	Trends of read size per operation
webtransport_write_bytes	counter	Total bytes written
webtransport_write_count	counter	Total write count
webtransport_write_size	trend	Trends of write size per operation
webtransport_datagrams_sent_count	counter	Number of sent datagrams
webtransport_datagrams_sent_bytes	counter	Total bytes sent in datagrams
webtransport_datagrams_received_count	counter	Number of received datagrams
webtransport_datagrams_received_bytes	counter	Total bytes received in datagrams

Documentation

Index

• type Connection
  • func (c *Connection) Close()
  • func (c *Connection) CloseAllStreams()
  • func (c *Connection) CloseStream()
  • func (c *Connection) CloseStreamById(id int64)
  • func (c *Connection) Connect(url string) bool
  • func (conn *Connection) Exports() modules.Exports
  • func (c *Connection) OpenStream() int64
  • func (c *Connection) ReadAll() []byte
  • func (c *Connection) ReadAtLeast(maxReadLength int, minReadLength int) []byte
  • func (c *Connection) ReadBuffer() [][]byte
  • func (c *Connection) ReadFull(expectedReadLength int) []byte
  • func (c *Connection) ReadStream(maxReadLength int)
  • func (c *Connection) ReceiveDatagram() []byte
  • func (c *Connection) SendDatagram(p []byte)
  • func (c *Connection) SetActiveStream(id int64)
  • func (c *Connection) StartReadToBuffer(maxReadLength int)
  • func (c *Connection) Write(p []byte)
• type RootModule
  • func (*RootModule) NewModuleInstance(vu modules.VU) modules.Instance
• type WTMetrics

Types

type Connection

type Connection struct {
	Session *webtransport.Session
	// contains filtered or unexported fields
}

func (*Connection) Close

func (c *Connection) Close()

func (*Connection) CloseAllStreams

func (c *Connection) CloseAllStreams()

func (*Connection) CloseStream

func (c *Connection) CloseStream()

func (*Connection) CloseStreamById

func (c *Connection) CloseStreamById(id int64)

func (*Connection) Connect

func (c *Connection) Connect(url string) bool

func (*Connection) Exports

func (conn *Connection) Exports() modules.Exports

func (*Connection) OpenStream

func (c *Connection) OpenStream() int64

func (*Connection) ReadAll

func (c *Connection) ReadAll() []byte

func (*Connection) ReadAtLeast

func (c *Connection) ReadAtLeast(maxReadLength int, minReadLength int) []byte

func (*Connection) ReadBuffer

func (c *Connection) ReadBuffer() [][]byte

func (*Connection) ReadFull

func (c *Connection) ReadFull(expectedReadLength int) []byte

func (*Connection) ReadStream

func (c *Connection) ReadStream(maxReadLength int)

func (*Connection) ReceiveDatagram

func (c *Connection) ReceiveDatagram() []byte

func (*Connection) SendDatagram

func (c *Connection) SendDatagram(p []byte)

func (*Connection) SetActiveStream

func (c *Connection) SetActiveStream(id int64)

func (*Connection) StartReadToBuffer

func (c *Connection) StartReadToBuffer(maxReadLength int)

func (*Connection) Write

func (c *Connection) Write(p []byte)

type RootModule

type RootModule struct{}

func (*RootModule) NewModuleInstance

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

type WTMetrics

type WTMetrics struct {
	StreamsWriteCount *metrics.Metric
	StreamsWriteBytes *metrics.Metric
	StreamsWriteSize  *metrics.Metric

	StreamsReadCount *metrics.Metric
	StreamsReadBytes *metrics.Metric
	StreamsReadSize  *metrics.Metric

	StreamsTotal *metrics.Metric

	DatagramsSentCount *metrics.Metric
	DatagramsSentBytes *metrics.Metric

	DatagramsRecvCount *metrics.Metric
	DatagramsRecvBytes *metrics.Metric
}