Function logWriter

provisioner/terraform/executor.go:603–608

logWriter creates a WriteCloser that will log each line of text at the given level. The WriteCloser must be closed by the caller to end logging, after which the returned channel will be closed to indicate that logging of the written data has finished. Failure to close the WriteCloser will leak a g

(sink logSink, level proto.LogLevel)

// by the caller to end logging, after which the returned channel will be closed to indicate that logging of the written
// data has finished.  Failure to close the WriteCloser will leak a goroutine.
func logWriter(sink logSink, level proto.LogLevel) (io.WriteCloser, <-chan any) {
	r, w := io.Pipe()
	done := make(chan any)
	go readAndLog(sink, r, done, level)
	return w, done
}

func readAndLog(sink logSink, r io.Reader, done chan<- any, level proto.LogLevel) {
	defer close(done)