Added full stream processing, pipeline workers, etc.

Full trigger logic now works.
Added pipeline workers, and test handler.
Added example configs
Lots of unittests.