Skip to content

Commit

Permalink
Using default CRD version for appmesh GVR
Browse files Browse the repository at this point in the history
Signed-off-by: Kiran Meduri <meduri@amazon.com>
  • Loading branch information
kiranmeduri committed Dec 15, 2021
1 parent 4e6ebd8 commit 2e7e3f1
Showing 1 changed file with 9 additions and 6 deletions.
15 changes: 9 additions & 6 deletions utils/appmesh/appmesh.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,11 +3,14 @@ package istio
import (
"context"

"github.com/argoproj/argo-rollouts/utils/defaults"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/runtime/schema"
"k8s.io/client-go/dynamic"
)

const AppMeshCRDGroup = "appmesh.k8s.aws"

func DoesAppMeshExist(dynamicClient dynamic.Interface, namespace string) bool {
_, err := dynamicClient.Resource(GetAppMeshVirtualServiceGVR()).Namespace(namespace).List(context.TODO(), metav1.ListOptions{Limit: 1})
if err != nil {
Expand All @@ -18,24 +21,24 @@ func DoesAppMeshExist(dynamicClient dynamic.Interface, namespace string) bool {

func GetAppMeshVirtualServiceGVR() schema.GroupVersionResource {
return schema.GroupVersionResource{
Group: "appmesh.k8s.aws",
Version: "v1beta2",
Group: AppMeshCRDGroup,
Version: defaults.GetAppMeshCRDVersion(),
Resource: "virtualservices",
}
}

func GetAppMeshVirtualRouterGVR() schema.GroupVersionResource {
return schema.GroupVersionResource{
Group: "appmesh.k8s.aws",
Version: "v1beta2",
Group: AppMeshCRDGroup,
Version: defaults.GetAppMeshCRDVersion(),
Resource: "virtualrouters",
}
}

func GetAppMeshVirtualNodeGVR() schema.GroupVersionResource {
return schema.GroupVersionResource{
Group: "appmesh.k8s.aws",
Version: "v1beta2",
Group: AppMeshCRDGroup,
Version: defaults.GetAppMeshCRDVersion(),
Resource: "virtualnodes",
}
}

0 comments on commit 2e7e3f1

Please sign in to comment.