follows a changes-feed and processes each entry, storing state in a leveldb - View it on GitHub