gofmt, also separate out changes and inde replies from the data stream for the bucket
change queue to keep the channels flowing