Skip to content

Get Pipeline Metrics

GET
/api/v1/pipelines/{route_id}/metrics

Get metrics for a route. Searches across all active executions.

route_id
required
Route Id
string

Successful Response

PipelineMetrics

Detailed pipeline metrics.

object
route_id
required
Route Id

Route identifier

string
messages_received
required
Messages Received

Total messages received

integer
messages_completed
required
Messages Completed

Total messages completed

integer
messages_failed
required
Messages Failed

Total messages failed

integer
messages_in_flight
required
Messages In Flight

Messages currently processing

integer
backpressure
Any of:
BackpressureMetrics

Backpressure controller metrics.

object
current_rate
required
Current Rate

Current processing rate (msgs/sec)

number
target_rate
required
Target Rate

Target rate from config (msgs/sec)

number
in_flight
required
In Flight

Current in-flight message count

integer
max_in_flight
required
Max In Flight

Maximum allowed in-flight messages

integer
timestamp
required
Timestamp

Metrics timestamp

string format: date-time

Resource not found

ErrorResponse

Standard error response matching FastAPI HTTPException format.

This model is used in OpenAPI response declarations for 4xx/5xx errors. The detail field matches FastAPI’s HTTPException structure.

object
detail
required
Detail

Error message (matches FastAPI HTTPException)

string
error_code
Any of:
string
correlation_id
Any of:
string
timestamp
Timestamp

Error timestamp

string format: date-time

Validation Error

HTTPValidationError
object
detail
Detail
Array<object>
ValidationError
object
loc
required
Location
Array
msg
required
Message
string
type
required
Error Type
string
input
Input
ctx
Context
object