A Stats Stream Processing Engine in Go