add yaml tag to our structs definitions

pkg/k8s/controller.go

@@ -244,35 +244,43 @@ func (c *Controller) getObjectEntities(obj interface{}, selector port.Selector,
 	}
 
 	entities := make([]port.Entity, 0, len(mappings))
-	objectsToMap := make([]map[string]interface{}, 0)
-	editedObject, ok := structuredObj.(map[string]interface{})
-	if !ok {
-		return nil, fmt.Errorf("error parsing object '%#v'", structuredObj)
-	}
-
 	if itemsToParse != "" {
+		editedObject, ok := structuredObj.(map[string]interface{})
+		if !ok {
+			return nil, fmt.Errorf("error parsing object '%#v'", structuredObj)
+		}
+
 		items, parseItemsError := jq.ParseArray(itemsToParse, structuredObj)
 		if parseItemsError != nil {
 			return nil, parseItemsError
 		}
 
 		for _, item := range items {
 			editedObject["item"] = item
-			objectsToMap = append(objectsToMap, editedObject)
+			selectorResult, err := isPassSelector(editedObject, selector)
+
+			if err != nil {
+				return nil, err
+			}
+
+			if selectorResult {
+				currentEntities, err := mapEntities(editedObject, mappings)
+				if err != nil {
+					return nil, err
+				}
+
+				entities = append(entities, currentEntities...)
+			}
 		}
 	} else {
-		objectsToMap = append(objectsToMap, editedObject)
-	}
-
-	for _, objectToMap := range objectsToMap {
-		selectorResult, err := isPassSelector(objectToMap, selector)
+		selectorResult, err := isPassSelector(structuredObj, selector)
 
 		if err != nil {
 			return nil, err
 		}
 
 		if selectorResult {
-			currentEntities, err := mapEntities(objectToMap, mappings)
+			currentEntities, err := mapEntities(structuredObj, mappings)
 			if err != nil {
 				return nil, err
 			}