- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 56 for addr (0.15 sec)
-
cni/pkg/ipset/nldeps_unspecified.go
return errors.New("not implemented on this platform") } func (m *realDeps) clearEntriesWithIP(name string, ip netip.Addr) error { return errors.New("not implemented on this platform") } func (m *realDeps) listEntriesByIP(name string) ([]netip.Addr, error) { return []netip.Addr{}, errors.New("not implemented on this platform")
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/ipset/nldeps_linux.go
} 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) } for _, entry := range res.Entries { addr, _ := netip.AddrFromSlice(entry.IP) ipList = append(ipList, addr) } return ipList, nil
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) -
cni/pkg/ipset/nldeps_mock.go
return args.Error(0) } func (m *MockedIpsetDeps) clearEntriesWithIP(name string, ip netip.Addr) error { args := m.Called(name, ip) return args.Error(0) } func (m *MockedIpsetDeps) listEntriesByIP(name string) ([]netip.Addr, error) { args := m.Called(name) return args.Get(0).([]netip.Addr), args.Error(1)
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/nodeagent/net_test.go
ObjectMeta: metav1.ObjectMeta{ Name: "foo", Namespace: "bar", UID: "123", }, Spec: corev1.PodSpec{ServiceAccountName: "sa"}, } // this is usually called after add. so manually add the pod uid for now fakens := newFakeNs(123) closed := fakens.closed workload := WorkloadInfo{ Workload: podToWorkload(pod), Netns: fakens, }
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/ztunnel/configdump/connections.go
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) } if w, f := workloadNames[ip]; f { return net.JoinHostPort(w, port) } return addr } fmt.Fprintln(w, "WORKLOAD\tDIRECTION\tLOCAL\tREMOTE\tREMOTE TARGET")
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/nodeagent/net.go
func addPodToHostNSIpset(pod *corev1.Pod, podIPs []netip.Addr, hostsideProbeSet *ipset.IPSet) error { // Add the pod UID as an ipset entry comment, so we can (more) easily find and delete // all relevant entries for a pod later. podUID := string(pod.ObjectMeta.UID) ipProto := uint8(unix.IPPROTO_TCP) var ipsetAddrErrs []error // For each pod IP for _, pip := range podIPs { // Add to host ipset
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/nodeagent/ztunnelserver.go
if err != nil { return nil, fmt.Errorf("failed to resolve unix addr: %w", err) } // remove potentially existing address // Remove unix socket before use, if one is leftover from previous CNI restart if err := os.Remove(addr); err != nil && !os.IsNotExist(err) { // Anything other than "file not found" is an error. return nil, fmt.Errorf("failed to remove unix://%s: %w", addr, err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 12.4K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
if _, ok := err.(ControlPlaneNotFoundError); ok { // Attempt to get the XDS address from the webhook and try again addr, err := getXdsAddressFromWebhooks(kubeClient) if err == nil { centralOpts.Xds = addr.host centralOpts.GCPProject = addr.gcpProject centralOpts.IstiodAddr = addr.istiod dialOpts, err := xds.DialOptions(centralOpts, istioNamespace, tokenServiceAccount, kubeClient) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
istioctl/pkg/util/configdump/workload.go
Hostname string `json:"hostname"` Addresses []string `json:"addresses"` Ports map[string]int `json:"ports"` } type ZtunnelDump struct { Workloads map[string]*ZtunnelWorkload `json:"by_addr"` Services map[string]*ZtunnelService `json:"by_vip"` Certificates []*CertsDump `json:"certificates"` } type CertsDump struct { Identity string `json:"identity"`
Go - Registered: Wed Apr 10 22:53:08 GMT 2024 - Last Modified: Fri Mar 22 16:24:22 GMT 2024 - 2.1K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
} { // go uses @ instead of \0 for abstract unix sockets addr := fmt.Sprintf("@testaddr%d", ztunnelTestCounter.Add(1)) ztun, err := newZtunnelServer(addr, pods) if err != nil { panic(err) } go ztun.Run(ctx) // now as a client connect confirm we and get snapshot resolvedAddr, err := net.ResolveUnixAddr("unixpacket", addr) if err != nil { panic(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0)