INNER CODE UNIT · Go

listAndEnqueueRequests

streamnative/function-mesh · controllers/common.go:395

func listAndEnqueueRequests(ctx context.Context, mgr manager.Manager, list client.ObjectList, namespace string) ([]reconcile.Request, error) {
	err := mgr.GetClient().List(ctx, list, client.InNamespace(namespace))
	if err != nil {
		mgr.GetLogger().Error(err, "failed to list resources in namespace: "+namespace)
		return nil, err
	}
	requests := []reconcile.Request{}
	items, err := meta.ExtractList(list)
	if err != nil {
		return nil, err
	}
	for _, item := range items {
		metaObj, err := meta.Accessor(item)
		if err != nil {
			return nil, err
		}
		requests = append(requests, reconcile.Request{
			NamespacedName: types.NamespacedName{Namespace: metaObj.GetNamespace(), Name: metaObj.GetName()},

View source record →