Implementation of MillWheel in Go