- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for listEntriesByIP (0.1 sec)
-
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) -
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)