func()

in appconfigmgrv2/controllers/network_policies.go [38:65]


func (r *AppEnvConfigTemplateV2Reconciler) reconcileNetworkPolicies(
	ctx context.Context,
	in *appconfig.AppEnvConfigTemplateV2,
) error {
	names := make(map[types.NamespacedName]bool)

	nps, err := networkPolicies(in)
	if err != nil {
		return fmt.Errorf("building policies: %v", err)
	}
	for _, np := range nps {
		if err := controllerutil.SetControllerReference(in, np, r.Scheme); err != nil {
			return fmt.Errorf("setting controller reference: %v", err)
		}

		if err := r.reconcileNetworkPolicy(ctx, np); err != nil {
			return fmt.Errorf("reconciling: %v", err)
		}

		names[types.NamespacedName{Name: np.Name, Namespace: np.Namespace}] = true
	}

	if err := r.garbageCollectNetworkPolicies(ctx, in, names); err != nil {
		return fmt.Errorf("garbage collecting: %v", err)
	}

	return nil
}