Major refactoring to allow for using unix sockets instead of forking a
process. This allows for having multiple databases and/or views that you
are watching for a given pipeline