-
Notifications
You must be signed in to change notification settings - Fork 58
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
* e2e: enable discovered apps Signed-off-by: jacklu <[email protected]> * use kubectl -k to deploy and undeploy discovered apps Signed-off-by: jacklu <[email protected]> --------- Signed-off-by: jacklu <[email protected]> Co-authored-by: jacklu <[email protected]>
- Loading branch information
Showing
14 changed files
with
673 additions
and
156 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,110 @@ | ||
| // SPDX-FileCopyrightText: The RamenDR authors | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| package deployers | ||
|
|
||
| import ( | ||
| "os" | ||
| "os/exec" | ||
|
|
||
| "github.com/ramendr/ramen/e2e/util" | ||
| "github.com/ramendr/ramen/e2e/workloads" | ||
| ) | ||
|
|
||
| type DiscoveredApps struct{} | ||
|
|
||
| func (d DiscoveredApps) GetName() string { | ||
| return "Disapp" | ||
| } | ||
|
|
||
| func (d DiscoveredApps) Deploy(w workloads.Workload) error { | ||
| name := GetCombinedName(d, w) | ||
| namespace := name | ||
|
|
||
| util.Ctx.Log.Info("enter Deploy " + name) | ||
|
|
||
| // create namespace in both dr clusters | ||
| if err := util.CreateNamespaceAndAddAnnotation(namespace); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| tempDir, err := os.MkdirTemp("", "ramen-") | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // Clean up by removing the temporary directory when done | ||
| defer os.RemoveAll(tempDir) | ||
|
|
||
| if err = CreateKustomizationFile(w, tempDir); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| drpolicy, err := util.GetDRPolicy(util.Ctx.Hub.CtrlClient, util.DefaultDRPolicyName) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| cmd := exec.Command("kubectl", "apply", "-k", tempDir, "-n", namespace, | ||
| "--context", drpolicy.Spec.DRClusters[0], "--timeout=5m") | ||
|
|
||
| // Run the command and capture the output | ||
| if out, err := cmd.Output(); err != nil { | ||
| util.Ctx.Log.Info(string(out)) | ||
|
|
||
| return err | ||
| } | ||
|
|
||
| // TODO: modify it based on shyam's comment | ||
| // return waitDeploymentReady(util.Ctx.C1.CtrlClient, namespace, "busybox") | ||
|
|
||
| util.Ctx.Log.Info(name + " is deployed") | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (d DiscoveredApps) Undeploy(w workloads.Workload) error { | ||
| name := GetCombinedName(d, w) | ||
| namespace := name // this namespace is in dr clusters | ||
|
|
||
| util.Ctx.Log.Info("enter Undeploy " + name) | ||
|
|
||
| drpolicy, err := util.GetDRPolicy(util.Ctx.Hub.CtrlClient, util.DefaultDRPolicyName) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| util.Ctx.Log.Info("starts to delete discovered apps on " + drpolicy.Spec.DRClusters[0]) | ||
|
|
||
| // delete app on both clusters | ||
| if err := DeleteDiscoveredApps(w, namespace, drpolicy.Spec.DRClusters[0]); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| util.Ctx.Log.Info("starts to delete discovered apps on " + drpolicy.Spec.DRClusters[1]) | ||
|
|
||
| if err := DeleteDiscoveredApps(w, namespace, drpolicy.Spec.DRClusters[1]); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| util.Ctx.Log.Info("starts to delete namespace " + namespace + " on " + drpolicy.Spec.DRClusters[0]) | ||
|
|
||
| // delete namespace on both clusters | ||
| if err := util.DeleteNamespace(util.Ctx.C1.CtrlClient, namespace); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| util.Ctx.Log.Info("starts to delete namespace " + namespace + " on " + drpolicy.Spec.DRClusters[1]) | ||
|
|
||
| if err := util.DeleteNamespace(util.Ctx.C2.CtrlClient, namespace); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| util.Ctx.Log.Info(name + " is undeployed") | ||
|
|
||
| return nil | ||
| } | ||
|
|
||
| func (d DiscoveredApps) IsWorkloadSupported(w workloads.Workload) bool { | ||
| return w.GetName() != "Deploy-cephfs" | ||
| } |
Oops, something went wrong.