Function NewClientFromContext

pkg/devspace/kubectl/client.go:105–143

NewClientFromContext creates a new kubernetes client from given context @Factory

(context, namespace string, switchContext bool, kubeLoader kubeconfig.Loader)

// NewClientFromContext creates a new kubernetes client from given context @Factory
func NewClientFromContext(context, namespace string, switchContext bool, kubeLoader kubeconfig.Loader) (Client, error) {
	clientConfig, activeContext, activeNamespace, isInCluster, err := util.NewClientByContext(context, namespace, switchContext, kubeLoader)
	if err != nil {
		return nil, err
	}

	restConfig, err := clientConfig.ClientConfig()
	if err != nil {
		return nil, err
	}
	restConfig.UserAgent = "DevSpace Version " + upgrade.GetVersion()
	restConfig.WrapTransport = func(rt http.RoundTripper) http.RoundTripper {
		return &devSpaceRoundTripper{
			roundTripper: rt,
			requestType:  "Regular",
			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")
				}
			},
		}
	}

	kubeClient, err := kubernetes.NewForConfig(restConfig)
	if err != nil {
		return nil, errors.Wrap(err, "new client")
	}

	return &client{
		Client:       kubeClient,
		clientConfig: clientConfig,
		restConfig:   restConfig,
		kubeLoader:   kubeLoader,

		namespace:      activeNamespace,
		currentContext: activeContext,
		isInCluster:    isInCluster,
	}, nil
}

// ClientConfig returns the underlying kube client config
func (client *client) ClientConfig() clientcmd.ClientConfig {