- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 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/ipset/nldeps_linux.go
if err != nil { delErrs = append(delErrs, fmt.Errorf("failed to delete IP %s from ipset %s: %w", entry.IP, name, err)) } } } return errors.Join(delErrs...) } func (m *realDeps) listEntriesByIP(name string) ([]netip.Addr, error) { var ipList []netip.Addr res, err := netlink.IpsetList(name) if err != nil { return ipList, fmt.Errorf("failed to list ipset %s: %w", name, err) }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jul 18 23:53:18 UTC 2024 - 4.1K 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)