Function EnsureNamespace

pkg/devspace/kubectl/util.go:160–185

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

}

func EnsureNamespace(ctx context.Context, client Client, namespace string, log log.Logger) error {
	_, err := client.KubeClient().CoreV1().Namespaces().Get(ctx, namespace, metav1.GetOptions{})
	if err != nil {
		if !kerrors.IsNotFound(err) {
			if kerrors.IsForbidden(err) {
				return nil
			}

			return errors.Wrap(err, "get namespace")
		}

		// create namespace
		_, err = client.KubeClient().CoreV1().Namespaces().Create(ctx, &corev1.Namespace{
			ObjectMeta: metav1.ObjectMeta{
				Name: namespace,
			},
		}, metav1.CreateOptions{})
		if err != nil && !kerrors.IsAlreadyExists(err) {
			return err
		}

		log.WithPrefixColor("info ", "cyan+b").Donef("Created namespace: %s", namespace)
	}

	return nil
}

// NewPortForwarder creates a new port forwarder object for the specified pods, ports and addresses
func NewPortForwarder(client Client, pod *corev1.Pod, ports []string, addresses []string, stopChan chan struct{}, readyChan chan struct{}, errorChan chan error) (*portforward.PortForwarder, error) {