What do you think about passing the channel in as an argument? This would allow processing updates from a bunch of services in the same goroutine as well as customizing buffering.