Function getObjectsFromTree

controllers/trace/util.go:639–674

(tree *tracev1.ObjectTreeNode, store ObjectRevisionStore, scheme *runtime.Scheme)

}

func getObjectsFromTree(tree *tracev1.ObjectTreeNode, store ObjectRevisionStore, scheme *runtime.Scheme) (map[model.GVKNObjKey]client.Object, error) {
	if tree == nil {
		return nil, nil
	}
	objectRef := objectReferenceToRef(&tree.Primary)
	revision := parseRevision(tree.Primary.ResourceVersion)
	obj, err := store.Get(objectRef, revision)
	if err != nil && !apierrors.IsNotFound(err) {
		return nil, err
	}
	objectMap := make(map[model.GVKNObjKey]client.Object)
	// cache loss after controller restarted, mock one
	if obj == nil {
		ro, err := scheme.New(objectRef.GroupVersionKind)
		if err != nil {
			return nil, err
		}
		obj, _ = ro.(client.Object)
		obj.SetNamespace(tree.Primary.Namespace)
		obj.SetName(tree.Primary.Name)
		obj.SetResourceVersion(tree.Primary.ResourceVersion)
		obj.SetUID(tree.Primary.UID)
	}
	objectMap[*objectRef] = obj

	for _, treeNode := range tree.Secondaries {
		secondaryMap, err := getObjectsFromTree(treeNode, store, scheme)
		if err != nil {
			return nil, err
		}
		for key, object := range secondaryMap {
			objectMap[key] = object
		}
	}
	return objectMap, nil
}

func getObjectTreeWithRevision(primary client.Object, ownershipRules []OwnershipRule, store ObjectRevisionStore, revision int64, scheme *runtime.Scheme) (*tracev1.ObjectTreeNode, error) {
	// find matched rules