Function StartAttach

pkg/devspace/services/attach/attach.go:60–147

StartAttach opens a new terminal

(
	ctx devspacecontext.Context,
	devContainer *latest.DevContainer,
	selector targetselector.TargetSelector,
	stdout io.Writer,
	stderr io.Writer,
	stdin io.Reader,
	parent *tomb.Tomb,
)

// StartAttach opens a new terminal
func StartAttach(
	ctx devspacecontext.Context,
	devContainer *latest.DevContainer,
	selector targetselector.TargetSelector,
	stdout io.Writer,
	stderr io.Writer,
	stdin io.Reader,
	parent *tomb.Tomb,
) (err error) {
	// restart on error
	defer func() {
		if err != nil {
			if ctx.IsDone() {
				return
			}

			ctx.Log().Infof("Restarting because: %s", err)
			select {
			case <-ctx.Context().Done():
				return
			case <-time.After(time.Second * 3):
			}
			err = StartAttach(ctx, devContainer, selector, stdout, stderr, stdin, parent)
			return
		}

		ctx.Log().Debugf("Stopped attach")
	}()

	before := log.GetBaseInstance().GetLevel()
	log.GetBaseInstance().SetLevel(logrus.PanicLevel)
	defer log.GetBaseInstance().SetLevel(before)

	container, err := selector.WithContainer(devContainer.Container).SelectSingleContainer(ctx.Context(), ctx.KubeClient(), ctx.Log())
	if err != nil {
		return err
	}

	ctx.Log().Infof("Attaching to pod:container %s:%s", ansi.Color(container.Pod.Name, "white+b"), ansi.Color(container.Container.Name, "white+b"))
	errChan := make(chan error)
	parent.Go(func() error {
		interruptpkg.Global.Stop()
		defer interruptpkg.Global.Start()

		errChan <- ctx.KubeClient().ExecStream(ctx.Context(), &kubectl.ExecStreamOptions{
			Pod:         container.Pod,
			Container:   container.Container.Name,
			TTY:         container.Container.TTY,
			Stdin:       stdin,
			Stdout:      stdout,
			Stderr:      stderr,
			SubResource: kubectl.SubResourceAttach,
		})
		return nil
	})

	select {
	case <-ctx.Context().Done():