Skip to main content
Version: 3.4.0

stalled

Reports when a stream has stopped getting events for a given duration

NOTE the semi-colons - this is not a multi-line bash script

Example

input:

input:
exec:
raw: true
command: |
echo '{"one":1}';
echo '{"two":2}';
sleep 2;
echo '{"three":3}';

action:

stalled:
timeout: 1s
marker:
- stalled

output:

{"_marker":"stalled","streaming":"yes"}
{"one":1}
{"two":2}
{"_marker":"stalled","streaming":"no"}
{"_marker":"stalled","streaming":"yes"}
{"three":3}

Field NameDescriptionTypeDefault
conditionOnly run this action if the condition the specified condition is metexpression-
timeoutHow long to wait before indicating that no data is flowingduration1m
use-document-markerIf specified we use end-of-document markers instead of the timeoutboolfalse
markerField value to add for when the Pipe is stalledarray of strings-
warningEnable warningsboolfalse
group-byA field containing group valuesfield-
time-fieldA field containing time in millisecs since epochfield-
save-fileOptional file to save the state of this action topath-

condition

Only run this action if the condition the specified condition is met

Type: expression

timeout

How long to wait before indicating that no data is flowing

Type: duration

use-document-marker

If specified we use end-of-document markers instead of the timeout

Type: bool

marker

Field value to add for when the Pipe is stalled

Type: array of strings

warning

Enable warnings

Type: bool

group-by

A field containing group values

Type: field

time-field

A field containing time in millisecs since epoch

Type: field

save-file

Optional file to save the state of this action to

Type: path