short-interval-control-pipeline-framework v1.1.3

Pipeline Library

The idea with this project is to investigate how to code a Processing Pipeline

The idea behind this is described here

How to install

npm install short-interval-control-pipeline-framework

How to use

Define a set of functions that represent the necessary processing steps in a pipeline including:

• generator - aka sensor - producer of events,measurements
• validator - validate that events conform to expectation
• detector - looks for stuff in events,measurements,
• consumer - combines events into higher level events,
• subscriber - capture subscription state,
• router - splits an event to subscribers,
• content - enriches the event,
• requestor - aka actuator - presents event to external actor