Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for NewRepair (0.12 sec)

  1. pkg/registry/core/service/ipallocator/controller/repair_test.go

    	fakeClient := fake.NewSimpleClientset()
    	ipregistry := &mockRangeRegistry{
    		item: &api.RangeAllocation{Range: "192.168.1.0/24"},
    	}
    	_, cidr, _ := netutils.ParseCIDRSloppy(ipregistry.item.Range)
    	r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), cidr, ipregistry, nil, nil)
    
    	if err := r.runOnce(); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 21.1K bytes
    - Viewed (0)
  2. pkg/registry/core/service/portallocator/controller/repair_test.go

    	clearMetrics()
    	fakeClient := fake.NewSimpleClientset()
    	registry := &mockRangeRegistry{
    		item: &api.RangeAllocation{Range: "100-200"},
    	}
    	pr, _ := net.ParsePortRange(registry.item.Range)
    	r := NewRepair(0, fakeClient.CoreV1(), fakeClient.EventsV1(), *pr, registry)
    
    	if err := r.runOnce(); err != nil {
    		t.Fatal(err)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 10.6K bytes
    - Viewed (0)
  3. pkg/registry/core/service/portallocator/controller/repair.go

    // avoid races between allocating a ports and using it.
    const numRepairsBeforeLeakCleanup = 3
    
    // NewRepair creates a controller that periodically ensures that all ports are uniquely allocated across the cluster
    // and generates informational warnings for a cluster that is not in sync.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  4. pkg/registry/core/service/ipallocator/controller/repair.go

    // avoid races between allocating an IP and using it.
    const numRepairsBeforeLeakCleanup = 3
    
    // NewRepair creates a controller that periodically ensures that all clusterIPs are uniquely allocated across the cluster
    // and generates informational warnings for a cluster that is not in sync.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Sep 30 15:46:06 UTC 2023
    - 13.8K bytes
    - Viewed (0)
  5. pkg/registry/core/rest/storage_core.go

    	}
    	p.startServiceNodePortsRepair = portallocatorcontroller.NewRepair(c.Services.IPRepairInterval, client.CoreV1(), client.EventsV1(), c.Services.NodePortRange, rangeRegistries.nodePort).RunUntil
    
    	// create service cluster ip repair controller
    	if !utilfeature.DefaultFeatureGate.Enabled(features.MultiCIDRServiceAllocator) {
    		p.startServiceClusterIPRepair = serviceipallocatorcontroller.NewRepair(
    			c.Services.IPRepairInterval,
    			client.CoreV1(),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:05 UTC 2023
    - 19.1K bytes
    - Viewed (0)
  6. pkg/registry/core/service/ipallocator/controller/repairip.go

    	workerLoopPeriod time.Duration
    
    	muTree sync.Mutex
    	tree   *iptree.Tree[string]
    
    	broadcaster events.EventBroadcaster
    	recorder    events.EventRecorder
    	clock       clock.Clock
    }
    
    // NewRepair creates a controller that periodically ensures that all clusterIPs are uniquely allocated across the cluster
    // and generates informational warnings for a cluster that is not in sync.
    func NewRepairIPAddress(interval time.Duration,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 24.7K bytes
    - Viewed (0)
Back to top