Function StartStream

pkg/devspace/services/sync/controller.go:630–663

(ctx context.Context, client kubectl.Client, pod *v1.Pod, container string, command []string, reader io.Reader, stdoutWriter io.Writer, buffer bool, log logpkg.Logger)

}

func StartStream(ctx context.Context, client kubectl.Client, pod *v1.Pod, container string, command []string, reader io.Reader, stdoutWriter io.Writer, buffer bool, log logpkg.Logger) error {
	stderrBuffer := &bytes.Buffer{}
	stderrReader, stderrWriter := io.Pipe()
	defer stderrWriter.Close()

	go func() {
		defer stderrReader.Close()
		s := scanner.NewScanner(stderrReader)
		for s.Scan() {
			log.Debug("Helper - " + s.Text())
		}
		if s.Err() != nil && s.Err() != context.Canceled {
			log.Warnf("Helper - Error streaming logs: %v", s.Err())
		}
	}()

	var stdErr io.Writer = stderrWriter
	if buffer {
		stdErr = io.MultiWriter(stderrBuffer, stderrWriter)
	}

	err := client.ExecStream(ctx, &kubectl.ExecStreamOptions{
		Pod:       pod,
		Container: container,
		Command:   command,
		Stdin:     reader,
		Stdout:    stdoutWriter,
		Stderr:    stdErr,
	})
	if err != nil {
		return fmt.Errorf("%s %v", stderrBuffer.String(), err)
	}
	return nil
}