amqp

package module

v0.0.0-...-a702f52 Latest Latest Go to latest Published: Apr 10, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This is an xk6 extension for k6 that uses the amqp protocol.

Usage: Example usage can be found in test.js

To build:

make build

To run:

First, you will have to make sure you've set the proper environment variables:

AMQP_TOPIC => the topic or endpoint you'd like to send your messages to. e.g. "topic://test-topic"

AMQP_CONN_STRING => the address of the endpoint to send the messages to. e.g. "amqp://admin:admin@localhost:5672/"

For convenience I'd recommend modifying the Makefile in the root and substituting your values in the command. Then you can simply use:

make run

This section is empty.

View Source

var ErrNotConnected = errors.New("not connected")

This section is empty.

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

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

Exports exposes the given object in ts

type Options struct {
	Uri   string
	Topic string
}

Common options for creating senders and receivers

type RootModule struct{}

func New() *RootModule

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

NewModuleInstance implements the modules.Module interface and returns a new instance for each VU.