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 Name	Description	Type	Default
condition	Only run this action if the condition the specified condition is met	expression	-
timeout	How long to wait before indicating that no data is flowing	duration	1m
use-document-marker	If specified we use end-of-document markers instead of the timeout	bool	false
marker	Field value to add for when the Pipe is stalled	array of strings	-
warning	Enable warnings	bool	false
group-by	A field containing group values	field	-
time-field	A field containing time in millisecs since epoch	field	-
save-file	Optional file to save the state of this action to	path	-

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