Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 23 for nw (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top