mirrors/kyverno
mirrors/kyverno
1
0
Fork 0
mirror of https://github.com/kyverno/kyverno.git synced 2025-01-20 18:52:16 +00:00
Code Activity

trying to change the way resource is stored in map

Browse source 
Signed-off-by: NoSkillGirl <singhpooja240393@gmail.com>
This commit is contained in:
NoSkillGirl 2021-06-15 23:35:22 +05:30
parent 09b1592f11
commit b8ada99d50
1 changed files with 35 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

58
pkg/kyverno/common/fetch.go
View file

@ -42,32 +42,40 @@ func GetResources(policies []*v1.ClusterPolicy, resourcePaths []string, dClient
resourceTypes = append(resourceTypes, kind)
}
var resourceMap map[string]map[string]map[string]*unstructured.Unstructured
// var resourceMap map[string]map[string]map[string]*unstructured.Unstructured
var resourceMap map[string]*unstructured.Unstructured
if cluster && dClient != nil {
resourceMap, err = getResourcesOfTypeFromCluster(resourceTypes, dClient, namespace)
if err != nil {
return nil, err
}
if len(resourcePaths) == 0 {
for _, rkm := range resourceMap {
for _, rm := range rkm {
for _, rr := range rm {
resources = append(resources, rr)
}
}
// for _, rkm := range resourceMap {
// for _, rm := range rkm {
// for _, rr := range rm {
// resources = append(resources, rr)
// }
// }
// }
for _, rr := range resourceMap {
resources = append(resources, rr)
}
} else {
for _, resourcePath := range resourcePaths {
lenOfResource := len(resources)
for _, rkm := range resourceMap {
for _, rm := range rkm {
for rn, rr := range rm {
if rn == resourcePath {
resources = append(resources, rr)
continue
}
}
}
// for _, rkm := range resourceMap {
// for _, rm := range rkm {
// for rn, rr := range rm {
// if rn == resourcePath {
// resources = append(resources, rr)
// continue
// }
// }
// }
// }
for _, rr := range resourceMap {
s := strings.Split("", "-")
resources = append(resources, rr)
}
if lenOfResource >= len(resources) {
if policyReport {
@ -180,11 +188,12 @@ func GetResource(resourceBytes []byte) ([]*unstructured.Unstructured, error) {
return resources, nil
}
func getResourcesOfTypeFromCluster(resourceTypes []string, dClient *client.Client, namespace string) (map[string]map[string]map[string]*unstructured.Unstructured, error) {
r := make(map[string]map[string]map[string]*unstructured.Unstructured)
func getResourcesOfTypeFromCluster(resourceTypes []string, dClient *client.Client, namespace string) (map[string]*unstructured.Unstructured, error) {
// r := make(map[string]map[string]map[string]*unstructured.Unstructured)
r := make(map[string]*unstructured.Unstructured)
for _, kind := range resourceTypes {
r[kind] = make(map[string]map[string]*unstructured.Unstructured)
// r[kind] = make(map[string]map[string]*unstructured.Unstructured)
resourceList, err := dClient.ListResource("", kind, namespace, nil)
if err != nil {
continue
@ -192,10 +201,13 @@ func getResourcesOfTypeFromCluster(resourceTypes []string, dClient *client.Clien
version := resourceList.GetAPIVersion()
for _, resource := range resourceList.Items {
if r[kind][resource.GetNamespace()] == nil {
r[kind][resource.GetNamespace()] = map[string]*unstructured.Unstructured{}
}
r[kind][resource.GetNamespace()][resource.GetName()] = resource.DeepCopy()
// if r[kind][resource.GetNamespace()] == nil {
// r[kind][resource.GetNamespace()] = map[string]*unstructured.Unstructured{}
// }
// r[kind][resource.GetNamespace()][resource.GetName()] = resource.DeepCopy()
key := kind + "-" + resource.GetNamespace() + "-" + resource.GetName()
r[key] = resource.DeepCopy()
resource.SetGroupVersionKind(schema.GroupVersionKind{
Group: "",
Version: version,