Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for syncCIDRs (0.18 sec)

  1. pkg/controller/servicecidrs/servicecidrs_controller_test.go

    			want:       true,
    		},
    	}
    	for _, tc := range tests {
    		t.Run(tc.name, func(t *testing.T) {
    			tCtx := ktesting.Init(t)
    			_, controller := newController(tCtx, t, tc.cidrs, tc.ips)
    			err := controller.syncCIDRs()
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			got, err := controller.canDeleteCIDR(tCtx, tc.cidrSynced)
    			if err != nil {
    				t.Fatal(err)
    			}
    			if got != tc.want {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 06:51:56 UTC 2024
    - 22K bytes
    - Viewed (0)
  2. pkg/controller/servicecidrs/servicecidrs_controller.go

    		logger.Info("Dropping ServiceCIDR out of the queue", "ServiceCIDR", key, "err", err)
    		c.queue.Forget(key)
    		utilruntime.HandleError(err)
    	}
    	return true
    }
    
    // syncCIDRs rebuilds the radix tree based from the informers cache
    func (c *Controller) syncCIDRs() error {
    	serviceCIDRList, err := c.serviceCIDRLister.List(labels.Everything())
    	if err != nil {
    		return err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 18K bytes
    - Viewed (0)
  3. pkg/registry/core/service/ipallocator/controller/repairip.go

    		return
    	}
    
    	klog.Warningf("Dropping ServiceCIDR %q out of the queue: %v", key, err)
    	r.cidrQueue.Forget(key)
    	runtime.HandleError(err)
    }
    
    // syncCIDRs rebuilds the radix tree based from the informers cache
    func (r *RepairIPAddress) syncCIDRs() error {
    	serviceCIDRList, err := r.serviceCIDRLister.List(labels.Everything())
    	if err != nil {
    		return err
    	}
    
    	tree := iptree.New[string]()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repairip_test.go

    			for _, cidr := range test.cidrs {
    				err := r.serviceCIDRStore.Add(cidr)
    				if err != nil {
    					t.Errorf("Unexpected error trying to add Service %v object: %v", cidr, err)
    				}
    			}
    			err := r.syncCIDRs()
    			if err != nil {
    				t.Fatal(err)
    			}
    			// override for testing
    			r.servicesSynced = func() bool { return true }
    			r.ipAddressSynced = func() bool { return true }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:06 UTC 2023
    - 20.3K bytes
    - Viewed (0)
Back to top