Golang ETL Pipeline