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 that no data is flowingduration-
markerField value to add for when the Pipe is stalledarray of string-
group-byA field containing group valuesfield-
time-fieldA field containing time in millisecs since epochepoch_millis-

timeout

How long to wait before indicating that no data is flowing

Type: duration

marker

Field value to add for when the Pipe is stalled

Type: array of string

group-by

A field containing group values

Type: field

time-field

A field containing time in millisecs since epoch

Type: epoch_millis