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
}