Add ingMgr Update func (#1869)

* add ingMgr Update func

* comment tweak to re-test

pkg/kube/ingress/ingress_extbeta.go

@@ -58,6 +58,16 @@ func (i *ExtensionsV1beta1) Create(ctx context.Context, ingress *unstructured.Un
 	return i.kubeCli.ExtensionsV1beta1().Ingresses(ing.Namespace).Create(ctx, &ing, opts)
 }
 
+// Update can be used to update an ingress resource in extensions v1beta1 apiVersion
+func (i *ExtensionsV1beta1) Update(ctx context.Context, ingress *unstructured.Unstructured, opts metav1.UpdateOptions) (runtime.Object, error) {
+	var ing extensionsv1beta1.Ingress
+	err := runtime.DefaultUnstructuredConverter.FromUnstructured(ingress.UnstructuredContent(), &ing)
+	if err != nil {
+		return nil, errors.Wrapf(err, "Failed converting runtime.Object to extensions/v1beta1 ingress")
+	}
+	return i.kubeCli.ExtensionsV1beta1().Ingresses(ing.Namespace).Update(ctx, &ing, opts)
+}
+
 // IngressPath can be used to get the backend path that is specified in the
 // ingress resource in `ns` namespace and name `releaseName-ingress`
 func (i *ExtensionsV1beta1) IngressPath(ctx context.Context, ns, releaseName string) (string, error) {

pkg/kube/ingress/ingress_netbeta.go

@@ -58,6 +58,16 @@ func (i *NetworkingV1beta1) Create(ctx context.Context, ingress *unstructured.Un
 	return i.kubeCli.NetworkingV1beta1().Ingresses(ing.Namespace).Create(ctx, &ing, opts)
 }
 
+// Update can be used to update an ingress resource in networking v1beta1 apiVersion
+func (i *NetworkingV1beta1) Update(ctx context.Context, ingress *unstructured.Unstructured, opts metav1.UpdateOptions) (runtime.Object, error) {
+	var ing netv1beta1.Ingress
+	err := runtime.DefaultUnstructuredConverter.FromUnstructured(ingress.UnstructuredContent(), &ing)
+	if err != nil {
+		return nil, errors.Wrapf(err, "Failed converting runtime.Object to networking/v1beta1 ingress")
+	}
+	return i.kubeCli.NetworkingV1beta1().Ingresses(ing.Namespace).Update(ctx, &ing, opts)
+}
+
 // IngressPath can be used to get the backend path that is specified in the
 // ingress resource in `ns` namespace and name `releaseName-ingress`
 func (i *NetworkingV1beta1) IngressPath(ctx context.Context, ns, releaseName string) (string, error) {

pkg/kube/ingress/ingress_netv1.go

@@ -58,6 +58,16 @@ func (i *NetworkingV1) Create(ctx context.Context, ingress *unstructured.Unstruc
 	return i.kubeCli.NetworkingV1().Ingresses(ing.Namespace).Create(ctx, &ing, opts)
 }
 
+// Update can be used to update an ingress resource in networking v1 apiVersion
+func (i *NetworkingV1) Update(ctx context.Context, ingress *unstructured.Unstructured, opts metav1.UpdateOptions) (runtime.Object, error) {
+	var ing netv1.Ingress
+	err := runtime.DefaultUnstructuredConverter.FromUnstructured(ingress.UnstructuredContent(), &ing)
+	if err != nil {
+		return nil, errors.Wrapf(err, "Failed converting runtime.Object to networking/v1 ingress")
+	}
+	return i.kubeCli.NetworkingV1().Ingresses(ing.Namespace).Update(ctx, &ing, opts)
+}
+
 // IngressPath can be used to get the backend path that is specified in the
 // ingress resource in `ns` namespace and name `releaseName-ingress`
 func (i *NetworkingV1) IngressPath(ctx context.Context, ns, releaseName string) (string, error) {

pkg/kube/ingress/ingressmgr.go

@@ -41,13 +41,15 @@ const (
 type Manager interface {
 	// List can be used to list all the ingress resources from `ns` namespace
 	List(ctx context.Context, ns string) (runtime.Object, error)
-	// Get can be used to to get ingress resource with name `name` in `ns` namespace
+	// Get can be used to get ingress resource with name `name` in `ns` namespace
 	Get(ctx context.Context, ns, name string) (runtime.Object, error)
 	// IngressPath can be used to get the backend path that is specified in the
 	// ingress resource in `ns` namespace and name `releaseName-ingress`
 	IngressPath(ctx context.Context, ns, releaseName string) (string, error)
 	// Create accepts an ingress in as runtime.Object and creates on the cluster
 	Create(ctx context.Context, ingress *unstructured.Unstructured, opts metav1.CreateOptions) (runtime.Object, error)
+	// Update accepts an ingress as a runtime.Object and updates it on the cluster
+	Update(ctx context.Context, ingress *unstructured.Unstructured, opts metav1.UpdateOptions) (runtime.Object, error)
 }
 
 // NewManager can be used to get the Manager based on the APIVersion of the ingress resources on the cluster