Golang implementation of streaming data processing