traverseControllerRef.go

func traverseControllerRef(controllerRef *metav1.OwnerReference, namespace string) (*metav1.OwnerReference, error) {
	obj, err := client.
		AppsV1().
		RESTClient().
		Get().
		Resource(fmt.Sprintf("%ss", controllerRef.Kind)).
		Name(controllerRef.Name).
		Namespace(namespace).
		Do().Raw()
	if err != nil {
		return nil, err
	}

	type ControllerMetadata struct {
		OwnerReference *metav1.OwnerReference `json:"metadata"`
	}
	controllerMetadata := ControllerMetadata{}
	if err := json.Unmarshal(obj, &controllerMetadata); err != nil {
		return nil, err
	}
	ref := controllerMetadata.OwnerReference
	if *ref.Controller {
		return traverseControllerRef(ref, namespace)
	}
	return controllerRef, nil
}