Actions

All action types supported by TestMesh flows — HTTP, database, Kafka, gRPC, WebSocket, Redis, mock servers, control flow, and transforms.

Every step has an action field that determines what work it performs. The config block structure varies by action type. This section covers every available action.

Protocol actions

http_request

Make HTTP requests with headers, auth, body, and response assertions.

database_query

Run SQL queries against PostgreSQL, MySQL, or MongoDB.

kafka_publish / kafka_consume

Produce messages to and consume messages from Kafka topics.

grpc_call

Invoke gRPC methods with proto reflection or proto file.

websocket

Connect, send, and receive WebSocket messages.

redis_get / redis_set

Read and write Redis keys with optional TTL.

Testing infrastructure

mock_server_*

Start, stop, verify, and configure mock HTTP servers.

Control flow and utilities

condition / for_each / parallel

Branching, looping, parallel execution, wait_until, log, delay, and assert.

transform

Extract, map, filter, and reshape data between steps.

Quick reference

Action	Description
`http_request`	Make an HTTP request
`database_query`	Run a SQL or MongoDB query
`kafka_publish`	Publish a message to a Kafka topic
`kafka_consume`	Consume messages from a Kafka topic
`grpc_call`	Call a gRPC method
`grpc_stream`	Open a streaming gRPC connection
`websocket`	WebSocket connect/send/receive
`redis_get`	Get a value from Redis
`redis_set`	Set a value in Redis
`neo4j.query`	Query Neo4j with Cypher
`neo4j.assert`	Query + inline assert
`minio.put`	Upload object to MinIO/S3
`minio.get`	Download object
`minio.delete`	Delete object
`minio.assert`	Assert object exists/metadata
`otel.inject`	Create span, inject traceparent
`otel.assert`	Query Tempo, assert on spans
`loki.query`	Query Loki with LogQL
`loki.assert`	Query Loki + assert
`prometheus.query`	Run PromQL instant query
`prometheus.assert`	Run PromQL + assert
`mock_server_start`	Start an HTTP mock server
`mock_server_stop`	Stop a mock server
`mock_server_verify`	Assert on received mock requests
`mock_server_reset_state`	Reset stateful mock data
`mock_server_update`	Add or update a mock endpoint
`condition`	If/then/else branching
`for_each`	Iterate over an array or range
`parallel`	Run steps concurrently
`wait_until`	Poll until a condition is true
`assert`	Standalone assertion step
`log`	Print a message to the execution log
`delay`	Sleep for a duration
`run_flow`	Call another flow as a sub-flow
`transform`	Extract and reshape variables