Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 278 for asSlice (0.83 sec)

  1. pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go

    			},
    			result: &workloadapi.Workload{
    				Uid:               "cluster0//Pod/ns/name",
    				Name:              "name",
    				Namespace:         "ns",
    				Addresses:         [][]byte{netip.AddrFrom4([4]byte{1, 2, 3, 4}).AsSlice()},
    				Network:           testNW,
    				CanonicalName:     "name",
    				CanonicalRevision: "latest",
    				WorkloadType:      workloadapi.WorkloadType_POD,
    				WorkloadName:      "name",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.3K bytes
    - Viewed (0)
  2. src/net/netip/inlining_test.go

    		"uint128.not",
    		"uint128.or",
    		"uint128.subOne",
    		"uint128.xor",
    	}
    	switch runtime.GOARCH {
    	case "amd64", "arm64":
    		// These don't inline on 32-bit.
    		wantInlinable = append(wantInlinable,
    			"Addr.AsSlice",
    			"Addr.Next",
    			"Addr.Prev",
    		)
    	}
    
    	for _, want := range wantInlinable {
    		if !got[want] {
    			t.Errorf("%q is no longer inlinable", want)
    			continue
    		}
    		delete(got, want)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 17:10:01 UTC 2024
    - 2K bytes
    - Viewed (0)
  3. pilot/pkg/serviceregistry/kube/controller/ambient/services_test.go

    				{
    					Name:      "name",
    					Namespace: "ns",
    					Hostname:  "a.example.com",
    					Addresses: []*workloadapi.NetworkAddress{{
    						Network: testNW,
    						Address: netip.AddrFrom4([4]byte{1, 2, 3, 4}).AsSlice(),
    					}},
    					Ports: []*workloadapi.Port{{
    						ServicePort: 80,
    						TargetPort:  80,
    					}},
    					SubjectAltNames: []string{"san1"},
    				},
    				{
    					Name:      "name",
    					Namespace: "ns",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 12:29:55 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  4. 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 to ipset %s: %w", ip, 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()),
    		Protocol: &ipProto,
    	})
    	if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 30 18:07:05 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go

    			TrustDomain:           pickTrustDomain(meshCfg),
    			Locality:              getWorkloadEntryLocality(&wle.Spec),
    		}
    
    		if addr, err := netip.ParseAddr(wle.Spec.Address); err == nil {
    			w.Addresses = [][]byte{addr.AsSlice()}
    		} else {
    			log.Warnf("skipping workload entry %s/%s; DNS Address resolution is not yet implemented", wle.Namespace, wle.Name)
    		}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.9K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    	assert.Equal(t,
    		s.lookup(s.addrXdsName("127.0.0.3"))[0].Address.GetWorkload().Waypoint.GetAddress().Address,
    		netip.MustParseAddr("10.0.0.2").AsSlice())
    
    	assert.Equal(t,
    		s.lookup(s.addrXdsName("127.0.0.4"))[0].Address.GetWorkload().Waypoint.GetAddress().Address,
    		netip.MustParseAddr("10.0.0.3").AsSlice())
    
    	// Lookup for service VIP should return Workload and Service AddressInfo objects
    	assert.Equal(t,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go

    	// We should now see the waypoint service IP
    	assert.Equal(t,
    		s.lookup(s.addrXdsName("127.0.0.3"))[0].Address.GetWorkload().Waypoint.GetAddress().Address,
    		netip.MustParseAddr("10.0.0.2").AsSlice())
    
    	// Add another one, expect the same result
    	s.addPods(t, "127.0.0.201", "waypoint2-ns-pod", "namespace-wide",
    		map[string]string{
    			constants.ManagedGatewayLabel: constants.ManagedGatewayMeshControllerLabel,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. src/net/addrselect.go

    	if b4 := b.To4(); b4 != nil {
    		b = b4
    	}
    	aAsSlice := a.AsSlice()
    	if len(aAsSlice) != len(b) {
    		return 0
    	}
    	// If IPv6, only up to the prefix (first 64 bits)
    	if len(aAsSlice) > 8 {
    		aAsSlice = aAsSlice[:8]
    		b = b[:8]
    	}
    	for len(aAsSlice) > 0 {
    		if aAsSlice[0] == b[0] {
    			cpl += 8
    			aAsSlice = aAsSlice[1:]
    			b = b[1:]
    			continue
    		}
    		bits := 8
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 09 00:24:06 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  9. src/net/cgo_unix.go

    	ip, err := netip.ParseAddr(addr)
    	if err != nil {
    		return nil, &DNSError{Err: "invalid address", Name: addr}
    	}
    	sa, salen := cgoSockaddr(IP(ip.AsSlice()), ip.Zone())
    	if sa == nil {
    		return nil, &DNSError{Err: "invalid address " + ip.String(), Name: addr}
    	}
    
    	return doBlockingWithCtx(ctx, addr, func() ([]string, error) {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Sun Apr 14 18:23:45 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  10. src/net/tcpsock.go

    // then the returned TCPAddr will contain a nil IP field, indicating an
    // address family-agnostic unspecified address.
    func TCPAddrFromAddrPort(addr netip.AddrPort) *TCPAddr {
    	return &TCPAddr{
    		IP:   addr.Addr().AsSlice(),
    		Zone: addr.Addr().Zone(),
    		Port: int(addr.Port()),
    	}
    }
    
    // TCPConn is an implementation of the [Conn] interface for TCP network
    // connections.
    type TCPConn struct {
    	conn
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Apr 15 03:10:07 UTC 2024
    - 13.7K bytes
    - Viewed (0)
Back to top