func ExecutePipeline(jobs ...job) {
    inputChannel := make(chan interface{})
    for _, job := range jobs {
        outputChannel := make(chan interface{}, 1)
        defer ExecuteJob(job, inputChannel, outputChannel)
        inputChannel = outputChannel
    }
}

func ExecuteJob(job job, inputChannel, outputChannel chan interface{}) {
    go job(inputChannel, outputChannel)
}