Function wakeUpAndPing

pkg/devspace/kubectl/client.go:319–364

(ctx context.Context, client Client, log log.Logger)

}

func wakeUpAndPing(ctx context.Context, client Client, log log.Logger) error {
	err := wakeUp(ctx, client, log)
	if err != nil {
		return err
	}

	// create ping config
	pingConfig := rest.CopyConfig(client.RestConfig())
	pingConfig.WrapTransport = func(rt http.RoundTripper) http.RoundTripper {
		return &devSpaceRoundTripper{
			roundTripper: rt,
			requestType:  "Ping",
			callback: func(response *http.Response) {
				if response.Header.Get("X-DevSpace-Response-Type") == "Blocked" {
					kill.StopDevSpace("Targeted Kubernetes environment has begun sleeping. Please restart DevSpace to wake up the environment")
				}
			},
		}
	}

	// create kube client
	kubeClient, err := kubernetes.NewForConfig(pingConfig)
	if err != nil {
		return err
	}

	// start pinging
	go func() {
		getter, _ := idle.NewIdleGetter()
		wait.UntilWithContext(ctx, func(ctx context.Context) {
			if getter != nil {
				amountIdle, err := getter.Idle()
				if err == nil && amountIdle > stopPingAfter {
					return
				}
			}

			_, err = kubeClient.CoreV1().Pods(client.Namespace()).List(ctx, metav1.ListOptions{LabelSelector: "devspace=ping"})
			if err != nil {
				log.Debugf("Error pinging Kubernetes environment: %v", err)
			}
		}, time.Minute)
	}()

	return nil
}

func wakeUp(ctx context.Context, client Client, log log.Logger) error {
	// check if environment is sleeping