stalled

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

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
timeoutHow long to wait before indicating if no data is flowingduration-
markerField value to add for when the Pipe is stalledarray of string-
input-fieldA field from where data is to be readstring-

timeout

How long to wait before indicating if no data is flowing

Type: duration

marker

Field value to add for when the Pipe is stalled

Type: array of string

input-field

A field from where data is to be read

Type: string