every

Runs a pipeline periodically at a fixed interval.

every interval:duration { … }

Description

The every operator repeats running a pipeline indefinitely at a fixed interval. The first run is starts directly when the outer pipeline itself starts.

Every interval, the executor spawns a new pipeline that runs to completion. If the pipeline runs longer than interval, the next run immediately starts.

Examples

Produce one event per second and enumerate the result

every 1s {
  from {}
}
enumerate

{"#": 0} // immediately
{"#": 1} // after 1s
{"#": 2} // after 2s
{"#": 3} // after 3s
// … continues like this

Fetch the results from an API every 10 minutes

every 10min {
  load_http "example.org/api/threats"
  read_json
}
publish "threat-feed"

See Also

cron