Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for listEntriesByIP (0.13 sec)

  1. cni/pkg/nodeagent/server_test.go

    		podUID,
    		false,
    	).Return(nil)
    
    	fakeIPSetDeps.On("addIP",
    		"foo-v4",
    		netip.MustParseAddr("2.2.2.2"),
    		ipProto,
    		podUID,
    		false,
    	).Return(nil)
    
    	fakeIPSetDeps.On("listEntriesByIP",
    		"foo-v4",
    	).Return([]netip.Addr{}, nil)
    
    	err := m.syncHostIPSets([]*corev1.Pod{pod})
    	assert.NoError(t, err)
    	fakeIPSetDeps.AssertExpectations(t)
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    	}
    
    	return nil
    }
    
    func pruneHostIPset(expected sets.Set[netip.Addr], hostsideProbeSet *ipset.IPSet) error {
    	actualIPSetContents, err := hostsideProbeSet.ListEntriesByIP()
    	if err != nil {
    		log.Warnf("unable to list IPSet: %v", err)
    		return err
    	}
    	actual := sets.New(actualIPSetContents...)
    	stales := actual.DifferenceInPlace(expected)
    
    	for staleIP := range stales {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
Back to top