Function ReadObjectTree

pkg/controller/kubebuilderx/utils.go:40–84

ReadObjectTree reads all objects owned by the root object which is type of 'T' with key in 'req'.

(ctx context.Context, reader client.Reader, req ctrl.Request, ml client.MatchingLabels, kinds ...client.ObjectList)

// ReadObjectTree reads all objects owned by the root object which is type of 'T' with key in 'req'.
func ReadObjectTree[T client.Object](ctx context.Context, reader client.Reader, req ctrl.Request, ml client.MatchingLabels, kinds ...client.ObjectList) (*ObjectTree, error) {
	tree := NewObjectTree()

	// read root object
	var obj T
	t := reflect.TypeOf(obj)
	if t.Kind() == reflect.Ptr {
		t = t.Elem()
	}
	rootObj := reflect.New(t).Interface()
	root, _ := rootObj.(T)
	if err := reader.Get(ctx, req.NamespacedName, root); err != nil {
		if apierrors.IsNotFound(err) {
			return tree, nil
		}
		return nil, err
	}
	tree.SetRoot(root)

	// init placement
	ctx = intoContext(ctx, placement(root))

	// read child objects
	inNS := client.InNamespace(req.Namespace)
	for _, list := range kinds {
		if err := reader.List(ctx, list, inNS, ml, inDataContext4C()); err != nil {
			return nil, err
		}
		// reflect get list.Items
		items := reflect.ValueOf(list).Elem().FieldByName("Items")
		l := items.Len()
		for i := 0; i < l; i++ {
			// get the underlying object
			object := items.Index(i).Addr().Interface().(client.Object)
			if len(object.GetOwnerReferences()) > 0 && !model.IsOwnerOf(root, object) {
				continue
			}
			if err := tree.Add(object); err != nil {
				return nil, err
			}
		}
	}

	return tree, nil
}

func placement(obj client.Object) string {
	if obj == nil || obj.GetAnnotations() == nil {