Go concurrency pipeline