- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for Ip (0.27 sec)
-
cni/pkg/repair/netns.go
return res, nil } func findNetworkIDByIP(ip string) (int, error) { link, err := getLinkWithDestinationOf(ip) if err != nil { return 0, fmt.Errorf("find link for %v: %v", ip, err) } return link.Attrs().NetNsID, nil } func getLinkWithDestinationOf(ip string) (netlink.Link, error) { routes, err := netlink.RouteListFiltered( netlink.FAMILY_V4, &netlink.Route{Dst: &net.IPNet{IP: net.ParseIP(ip), Mask: net.CIDRMask(32, 32)}},
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/workload.go
} for _, wl := range verifiedWorkloads { var ip string if len(wl.WorkloadIPs) > 0 { ip = wl.WorkloadIPs[0] } if filter.Verbose { waypoint := waypointName(wl, zDump.Services) fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\t%v\n", wl.Namespace, wl.Name, ip, wl.Node, waypoint, wl.Protocol) } else { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", wl.Namespace, wl.Name, ip, wl.Node) } } return w.Flush() }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 23 21:30:30 GMT 2024 - 4K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
ipProto := uint8(unix.IPPROTO_TCP) var ipsetAddrErrs []error // For each pod IP for _, pip := range podIPs { // Add to host ipset log.Debugf("adding pod %s probe to ipset %s with ip %s", pod.Name, hostsideProbeSet.Prefix, pip) // Add IP/port combo to set. Note that we set Replace to true - a pod ip/port combo already being // in the set is perfectly fine, and something we can always safely overwrite, so we will.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/ipset/nldeps_mock.go
return args.Error(0) } func (m *MockedIpsetDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error { args := m.Called(name, ip, ipProto, comment, replace) return args.Error(0) } func (m *MockedIpsetDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error { args := m.Called(name, ip, ipProto) return args.Error(0) } func (m *MockedIpsetDeps) flush(name string) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 1.8K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
"!", "-d", iptablesconstants.IPVersionSpecific, // ignore traffic to localhost ip, as this rule means to catch traffic to pod ip. "-p", iptablesconstants.TCP, "-i", "lo", "-j", "ACCEPT") // CLI: -A ISTIO_PRERT -p tcp -m tcp --dport <INPORT> -m mark ! --mark 0x539/0xfff -j TPROXY --on-port <INPORT> --on-ip 127.0.0.1 --tproxy-mark 0x111/0xfff //
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
podStatus = corev1.PodStatus{ PodIP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164", PodIPs: []corev1.PodIP{{IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164"}, {IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3165"}}, } } else { podStatus = corev1.PodStatus{ PodIP: "2.2.2.2", PodIPs: []corev1.PodIP{{IP: "2.2.2.2"}, {IP: "3.3.3.3"}}, } } return &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "foo",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
equality = "^" case *matcher.Matcher_MatcherTree_CustomMatch: tc := v.CustomMatch.GetTypedConfig() switch tc.TypeUrl { case IPMatcher: ip := protoconv.SilentlyUnmarshalAny[matcher.IPMatcher](tc) m = map[string]*matcher.Matcher_OnMatch{} for _, rm := range ip.GetRangeMatchers() { for _, r := range rm.Ranges { cidr := r.AddressPrefix pl := r.PrefixLen.GetValue() if pl != 32 && pl != 128 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_linux.go
Comment: comment, IP: net.IP(ip.AsSlice()), Protocol: &ipProto, Replace: replace, }) if err != nil { return fmt.Errorf("failed to add IP %s with and proto %d to ipset %s: %w", ip, ipProto, name, err) } return nil } func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error { err := netlink.IpsetDel(name, &netlink.IPSetEntry{ IP: net.IP(ip.AsSlice()),
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.9K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/connections.go
for netIP, s := range d.Services { _, ip, _ := strings.Cut(netIP, "/") serviceNames[ip] = s.Hostname } for netIP, s := range d.Workloads { _, ip, _ := strings.Cut(netIP, "/") workloadNames[ip] = s.Name + "." + s.Namespace } lookupIP := func(addr string) string { if filter.Raw { return addr } ip, port, _ := net.SplitHostPort(addr) if s, f := serviceNames[ip]; f { return net.JoinHostPort(s, port) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 22 15:39:28 GMT 2024 - 3.3K bytes - Viewed (0) -
cni/pkg/ipset/nldeps_unspecified.go
return errors.New("not implemented on this platform") } func (m *realDeps) addIP(name string, ip netip.Addr, ipProto uint8, comment string, replace bool) error { return errors.New("not implemented on this platform") } func (m *realDeps) deleteIP(name string, ip netip.Addr, ipProto uint8) error { return errors.New("not implemented on this platform") } func (m *realDeps) flush(name string) error {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 1.8K bytes - Viewed (0)