Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for newBitset (0.12 sec)

  1. pkg/kubelet/pod_workers_test.go

    			if reflect.DeepEqual(possible, syncPodRecords) {
    				match = true
    				break
    			}
    		}
    		if !match {
    			t.Fatalf("unexpected history for pod %v: %#v", i, syncPodRecords)
    		}
    	}
    }
    
    func newUIDSet(uids ...types.UID) sets.Set[string] {
    	set := sets.New[string]()
    	for _, uid := range uids {
    		set.Insert(string(uid))
    	}
    	return set
    }
    
    type terminalPhaseSync struct {
    	lock     sync.Mutex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  2. pkg/proxy/ipvs/proxier.go

    		logger:                logger,
    	}
    	// initialize ipsetList with all sets we needed
    	proxier.ipsetList = make(map[string]*IPSet)
    	for _, is := range ipsetInfo {
    		proxier.ipsetList[is.name] = NewIPSet(ipset, is.name, is.setType, (ipFamily == v1.IPv6Protocol), is.comment)
    	}
    	burstSyncs := 2
    	logger.V(2).Info("ipvs sync params", "minSyncPeriod", minSyncPeriod, "syncPeriod", syncPeriod, "burstSyncs", burstSyncs)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top