Function StartLogs

pkg/devspace/services/logs/logs.go:33–103

StartLogs print the logs and then attaches to the container

(
	ctx devspacecontext.Context,
	devContainer *latest.DevContainer,
	selector targetselector.TargetSelector,
)

// StartLogs print the logs and then attaches to the container
func StartLogs(
	ctx devspacecontext.Context,
	devContainer *latest.DevContainer,
	selector targetselector.TargetSelector,
) (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 = StartLogs(ctx, devContainer, selector)
			return
		}

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

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

	lines := int64(500)
	if devContainer.Logs.LastLines > 0 {
		lines = devContainer.Logs.LastLines
	}

	ctx.Log().Infof("Streaming logs of pod:container %s:%s", ansi.Color(containerObj.Pod.Name, "white+b"), ansi.Color(containerObj.Container.Name, "white+b"))
	reader, err := ctx.KubeClient().Logs(ctx.Context(), containerObj.Pod.Namespace, containerObj.Pod.Name, containerObj.Container.Name, false, &lines, true)
	if err != nil {
		return err
	}

	errChan := make(chan error)
	go func() {
		s := scanner.NewScanner(reader)
		for s.Scan() {
			if devContainer.Container != "" {
				ctx.Log().Info(devContainer.Container + ": " + s.Text())
			} else {
				ctx.Log().Info(s.Text())
			}
		}

		errChan <- s.Err()
	}()

	select {
	case <-ctx.Context().Done():
		_ = reader.Close()