Skip to main content
Version: Next

assert_throughput

Emits a warning if the pipeline does not have the expected throughput

assert_throughput min_events:int, within=duration, [retries=int]

Description

The assert_throghput operator checks a pipeline's throughput, emitting a warning if the minimum specified throughput is unmet, and optionally an error if the number of retries is exceeded.

Examples

Require 1,000 events per second, failing if the issue persists for 30s

from "udp://0.0.0.0:514" { read_syslog }
assert_throughput 1k, within=1s, retries=30

See Also

assert