- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 23 for nw (0.02 sec)
-
pilot/pkg/serviceregistry/kube/controller/network.go
// TODO label based gateways could support being the gateway for multiple networks if nw := svc.Attributes.Labels[label.TopologyNetwork.Name]; nw != "" { if gwPortStr := svc.Attributes.Labels[label.NetworkingGatewayPort.Name]; gwPortStr != "" { if gwPort, err := strconv.Atoi(gwPortStr); err == nil { return []model.NetworkGateway{{Port: uint32(gwPort), Network: network.ID(nw)}} } log.Warnf("could not parse %q for %s on %s/%s; defaulting to %d",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
src/strings/replace.go
continue } if last != i { nw, err := sw.WriteString(s[last:i]) n += nw if err != nil { return n, err } } last = i + 1 nw, err := w.Write(r.replacements[b]) n += nw if err != nil { return n, err } } if last != len(s) { var nw int nw, err = sw.WriteString(s[last:]) n += nw } return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Oct 13 17:10:31 UTC 2023 - 14.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/interface.go
func getIPFromInterface(intfName string, forFamily AddressFamily, nw networkInterfacer) (net.IP, error) { intf, err := nw.InterfaceByName(intfName) if err != nil { return nil, err } if isInterfaceUp(intf) { addrs, err := nw.Addrs(intf) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jul 27 07:07:03 UTC 2022 - 14.7K bytes - Viewed (0) -
internal/ioutil/ioutil.go
} // buf is not aligned, hence use writeUnaligned() // for the remainder un, err = w.Write(buf[len(buf)-remain:]) nw += int64(un) } if nw > 0 { written += nw } if err != nil { return written, err } if nw != int64(len(buf)) { return written, io.ErrShortWrite } if totalSize > 0 && written == totalSize {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed May 22 23:07:14 UTC 2024 - 10.2K bytes - Viewed (0) -
pilot/pkg/model/network.go
} return SortGateways(out) } func (gws *NetworkGateways) GatewaysForNetwork(nw network.ID) []NetworkGateway { gws.mu.RLock() defer gws.mu.RUnlock() if gws.byNetwork == nil { return nil } return gws.byNetwork[nw] } func (gws *NetworkGateways) GatewaysForNetworkAndCluster(nw network.ID, c cluster.ID) []NetworkGateway { gws.mu.RLock() defer gws.mu.RUnlock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 16.9K bytes - Viewed (0) -
src/encoding/base64/base64.go
d.err = io.ErrUnexpectedEOF } return 0, d.err } // Decode chunk into p, or d.out and then p if p is too small. nr := d.nbuf / 4 * 4 nw := d.nbuf / 4 * 3 if nw > len(p) { nw, d.err = d.enc.Decode(d.outbuf[:], d.buf[:nr]) d.out = d.outbuf[:nw] n = copy(p, d.out) d.out = d.out[n:] } else { n, d.err = d.enc.Decode(p, d.buf[:nr]) } d.nbuf -= nr copy(d.buf[:d.nbuf], d.buf[nr:])
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Sep 08 19:04:28 UTC 2023 - 17.6K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/net/interface_test.go
t.Errorf("case[%v]: expected %v, got %v .err : %v", tc.tcase, tc.expected, ip, err) } } } func TestAddrs(t *testing.T) { var nw networkInterfacer = validNetworkInterface{} intf := net.Interface{Index: 0, MTU: 0, Name: "eth3", HardwareAddr: nil, Flags: 0} addrs, err := nw.Addrs(&intf) if err != nil { t.Errorf("expected no error got : %v", err) } if len(addrs) != 2 { t.Errorf("expected addrs: 2 got null")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 10 07:29:34 UTC 2023 - 33.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
// 1. check the pod/workloadEntry label if nw := labels[label.TopologyNetwork.Name]; nw != "" { return network.ID(nw) } // 2. check the system namespace labels if nw := c.networkFromSystemNamespace(); nw != "" { return nw } // 3. check the meshNetworks config if nw := c.networkFromMeshNetworks(endpointIP); nw != "" { return nw } return "" }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/proxy/util/nodeport_addresses_test.go
ips: sets.New[string]("2001:db8::1", "::1"), }, }, }, } for _, tc := range testCases { t.Run(tc.name, func(t *testing.T) { nw := fake.NewFakeNetwork() for _, pair := range tc.itfAddrsPairs { nw.AddInterfaceAddr(&pair.itf, pair.addrs) } for _, family := range []v1.IPFamily{v1.IPv4Protocol, v1.IPv6Protocol} { npa := NewNodePortAddresses(family, tc.cidrs)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 13.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network_test.go
meshNetworks.SetNetworks(nil) expectGateways(t, 0) }) } func addLabeledServiceGateway(t *testing.T, c *FakeController, nw string) { svc := &corev1.Service{ ObjectMeta: metav1.ObjectMeta{Name: "istio-labeled-gw", Namespace: "arbitrary-ns", Labels: map[string]string{ label.TopologyNetwork.Name: nw, }}, Spec: corev1.ServiceSpec{ Type: corev1.ServiceTypeLoadBalancer,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 10.7K bytes - Viewed (0)