Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newBitset (0.22 sec)

  1. cni/pkg/ipset/ipset.go

    // doesn't support creating `list:set` types yet (is in main branch tho).
    // So this will actually create 2 underlying ipsets, one for v4 and one for v6
    func NewIPSet(name string, v6 bool, deps NetlinkIpsetDeps) (IPSet, error) {
    	var err error
    	set := IPSet{
    		V4Name: fmt.Sprintf(V4Name, name),
    		Deps:   deps,
    		Prefix: name,
    	}
    	err = deps.ipsetIPHashCreate(set.V4Name, false)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 22:24:38 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    //
    // We will unconditionally flush our set before use here, so it shouldn't matter.
    func createHostsideProbeIpset(isV6 bool) (ipset.IPSet, error) {
    	linDeps := ipset.RealNlDeps()
    	probeSet, err := ipset.NewIPSet(iptables.ProbeIPSet, isV6, linDeps)
    	if err != nil {
    		return probeSet, err
    	}
    	probeSet.Flush()
    	return probeSet, nil
    }
    
    func (s *Server) Start() {
    	log.Info("CNI ambient server starting")
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 31 21:45:18 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  3. 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)
  4. 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)
  5. pkg/proxy/ipvs/proxier_test.go

    	netlinkHandle.SetLocalAddresses("eth0", nodeIPs...)
    
    	// initialize ipsetList with all sets we needed
    	ipsetList := make(map[string]*IPSet)
    	for _, is := range ipsetInfo {
    		ipsetList[is.name] = NewIPSet(ipset, is.name, is.setType, false, is.comment)
    	}
    	p := &Proxier{
    		svcPortMap:            make(proxy.ServicePortMap),
    		serviceChanges:        proxy.NewServiceChangeTracker(newServiceInfo, ipFamily, nil, nil),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
Back to top