Part of Jetstream framework that:
- composes a pipe from two or more components
- adds instrumentation in between every ‘slot’ or ‘connection’ between
two components
- runs the pipe, indexing received records, performing logging and
producing a report of the run