aboutsummaryrefslogtreecommitdiffstats
path: root/src/k8splugin/internal/app/query.go
diff options
context:
space:
mode:
authorLukasz Rajewski <lukasz.rajewski@orange.com>2022-02-03 19:18:07 +0100
committerLukasz Rajewski <lukasz.rajewski@orange.com>2022-02-23 14:27:01 +0100
commit88ecb1f9dfeded36e7fd74c776daefcaf67f8ae2 (patch)
tree321eb34967dd32a43d7e3ac62b5fd664e5b2231b /src/k8splugin/internal/app/query.go
parent1f92a0ec4ea037089b82e3f80bb030f34fab64f0 (diff)
ConfigAPI and Query API improvements
- Config Template create from the definition content - Missing CRUD Config handlers added - Improved Rollback and Config delete - Query API name filtering improved Issue-ID: MULTICLOUD-1437 Signed-off-by: Lukasz Rajewski <lukasz.rajewski@orange.com> Change-Id: Iec8ec6d03746085f294d9318a252f1ae45d3b9c8
Diffstat (limited to 'src/k8splugin/internal/app/query.go')
-rw-r--r--src/k8splugin/internal/app/query.go16
1 files changed, 1 insertions, 15 deletions
diff --git a/src/k8splugin/internal/app/query.go b/src/k8splugin/internal/app/query.go
index 251b14e6..6a1b3516 100644
--- a/src/k8splugin/internal/app/query.go
+++ b/src/k8splugin/internal/app/query.go
@@ -19,9 +19,6 @@
package app
import (
- "github.com/onap/multicloud-k8s/src/k8splugin/internal/helm"
- "k8s.io/apimachinery/pkg/runtime/schema"
-
pkgerrors "github.com/pkg/errors"
)
@@ -64,7 +61,7 @@ func (v *QueryClient) Query(namespace, cloudRegion, apiVersion, kind, name, labe
}
var resourcesStatus []ResourceStatus
- if labels != "" {
+ if name != "" {
resList, err := k8sClient.queryResources(apiVersion, kind, labels, namespace)
if err != nil {
return QueryStatus{}, pkgerrors.Wrap(err, "Querying Resources")
@@ -76,22 +73,11 @@ func (v *QueryClient) Query(namespace, cloudRegion, apiVersion, kind, name, labe
for _, res := range resList {
if res.Name == name {
resourcesStatus = append(resourcesStatus, res)
- break
}
}
} else {
resourcesStatus = resList
}
- } else if name != "" {
- resIdentifier := helm.KubernetesResource{
- Name: name,
- GVK: schema.FromAPIVersionAndKind(apiVersion, kind),
- }
- res, err := k8sClient.GetResourceStatus(resIdentifier, namespace)
- if err != nil {
- return QueryStatus{}, pkgerrors.Wrap(err, "Querying Resource")
- }
- resourcesStatus = []ResourceStatus{res}
} else {
resList, err := k8sClient.queryResources(apiVersion, kind, labels, namespace)
if err != nil {