Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 46 for servicecidrs (0.28 sec)

  1. pkg/controller/servicecidrs/servicecidrs_controller.go

    				serviceCIDRs.Insert(v.UnsortedList()...)
    				return false
    			})
    			if serviceCIDRs.Len() == 1 && serviceCIDRs.Has(serviceCIDR.Name) {
    				hasParent = false
    			}
    		}
    	}
    
    	// All the existing IP addresses will be contained on the parent ServiceCIDRs,
    	// it is safe to delete, remove the finalizer.
    	if hasParent {
    		logger.V(2).Info("Removing finalizer for ServiceCIDR", "ServiceCIDR", serviceCIDR.String())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18K bytes
    - Viewed (0)
  2. pkg/controller/servicecidrs/servicecidrs_controller_test.go

    func makeServiceCIDR(name, primary, secondary string) *networkingapiv1alpha1.ServiceCIDR {
    	serviceCIDR := &networkingapiv1alpha1.ServiceCIDR{
    		ObjectMeta: metav1.ObjectMeta{
    			Name: name,
    		},
    		Spec: networkingapiv1alpha1.ServiceCIDRSpec{},
    	}
    	serviceCIDR.Spec.CIDRs = append(serviceCIDR.Spec.CIDRs, primary)
    	if secondary != "" {
    		serviceCIDR.Spec.CIDRs = append(serviceCIDR.Spec.CIDRs, secondary)
    	}
    	return serviceCIDR
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 22K bytes
    - Viewed (0)
  3. cmd/kube-controller-manager/app/networking.go

    		}}
    }
    func startServiceCIDRsController(ctx context.Context, controllerContext ControllerContext, controllerName string) (controller.Interface, bool, error) {
    	go servicecidrs.NewController(
    		ctx,
    		controllerContext.InformerFactory.Networking().V1alpha1().ServiceCIDRs(),
    		controllerContext.InformerFactory.Networking().V1alpha1().IPAddresses(),
    		controllerContext.ClientBuilder.ClientOrDie("service-cidrs-controller"),
    	).Run(ctx, 5)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  4. pkg/controlplane/controller/defaultservicecidr/default_servicecidr_controller.go

    			CIDRs: c.cidrs,
    		},
    	}
    	serviceCIDR, err = c.client.NetworkingV1alpha1().ServiceCIDRs().Create(context.Background(), serviceCIDR, metav1.CreateOptions{})
    	if err != nil && !apierrors.IsAlreadyExists(err) {
    		c.eventRecorder.Eventf(serviceCIDR, v1.EventTypeWarning, "KubernetesDefaultServiceCIDRError", "The default ServiceCIDR can not be created")
    		return err
    	}
    	c.syncStatus(serviceCIDR)
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  5. pkg/registry/core/service/ipallocator/cidrallocator.go

    		klog.V(2).Infof("Finished sync for CIDRs took %v", time.Since(now))
    	}()
    
    	serviceCIDRs, err := c.serviceCIDRLister.List(labels.Everything())
    	if err != nil {
    		return err
    	}
    
    	cidrsSet := sets.New[string]()
    	cidrReady := map[string]bool{}
    	for _, serviceCIDR := range serviceCIDRs {
    		ready := true
    		if !isReady(serviceCIDR) || !serviceCIDR.DeletionTimestamp.IsZero() {
    			ready = false
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.2K bytes
    - Viewed (0)
  6. staging/src/k8s.io/api/networking/v1alpha1/generated.proto

    }
    
    // ServiceCIDRList contains a list of ServiceCIDR objects.
    message ServiceCIDRList {
      // Standard object's metadata.
      // More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#metadata
      // +optional
      optional .k8s.io.apimachinery.pkg.apis.meta.v1.ListMeta metadata = 1;
    
      // items is the list of ServiceCIDRs.
      repeated ServiceCIDR items = 2;
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 28 15:34:11 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  7. pkg/proxy/nftables/proxier.go

    	// staleChains contains information about chains to be deleted later
    	staleChains map[string]time.Time
    
    	// serviceCIDRs is a comma separated list of ServiceCIDRs belonging to the IPFamily
    	// which proxier is operating on, can be directly consumed by knftables.
    	serviceCIDRs string
    
    	logger klog.Logger
    }
    
    // Proxier implements proxy.Provider
    var _ proxy.Provider = &Proxier{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  8. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go

    				rbacv1helpers.NewRule("get", "list", "watch", "patch", "update").Groups(networkingGroup).Resources("servicecidrs").RuleOrDie(),
    				rbacv1helpers.NewRule("patch", "update").Groups(networkingGroup).Resources("servicecidrs/finalizers").RuleOrDie(),
    				rbacv1helpers.NewRule("patch", "update").Groups(networkingGroup).Resources("servicecidrs/status").RuleOrDie(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  9. pkg/kubeapiserver/default_storage_factory_builder.go

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 20:14:51 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. pkg/proxy/metaproxier/meta_proxier.go

    func (proxier *metaProxier) OnNodeSynced() {
    	proxier.ipv4Proxier.OnNodeSynced()
    	proxier.ipv6Proxier.OnNodeSynced()
    }
    
    // OnServiceCIDRsChanged is called whenever a change is observed
    // in any of the ServiceCIDRs, and provides complete list of service cidrs.
    func (proxier *metaProxier) OnServiceCIDRsChanged(cidrs []string) {
    	proxier.ipv4Proxier.OnServiceCIDRsChanged(cidrs)
    	proxier.ipv6Proxier.OnServiceCIDRsChanged(cidrs)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Jan 21 14:28:37 UTC 2024
    - 5.9K bytes
    - Viewed (0)
Back to top