Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 941 for ipaddresses (0.19 sec)

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

    // To tackle this, we need a ip2instance map like what we have in service entry.
    func (c *Controller) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget {
    	if len(proxy.IPAddresses) > 0 {
    		proxyIP := proxy.IPAddresses[0]
    		// look up for a WorkloadEntry; if there are multiple WorkloadEntry(s)
    		// with the same IP, choose one deterministically
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  2. pkg/util/iptree/iptree.go

    // prefixContainIP returns true if the given IP is contained with the prefix,
    // is not the network address and also, if IPv4, is not the broadcast address.
    // This is required because the Kubernetes allocators reserve these addresses
    // so IPAddresses can not block deletion of this ranges.
    func prefixContainIP(prefix netip.Prefix, ip netip.Addr) bool {
    	// if the IP is the network address is not contained
    	if prefix.Masked().Addr() == ip {
    		return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 31 21:05:04 UTC 2023
    - 17.7K bytes
    - Viewed (0)
  3. pilot/pkg/networking/core/listener_builder_test.go

    	test.SetForTest(t, &features.EnableAdditionalIpv4OutboundListenerForIpv6Only, true)
    	cg := NewConfigGenTest(t, TestOptions{Services: testServices})
    	proxy := cg.SetupProxy(&model.Proxy{IPAddresses: []string{"1111:2222::1"}})
    
    	listeners := buildListeners(t, TestOptions{Services: testServices}, proxy)
    	vo := xdstest.ExtractListener(model.VirtualOutboundListenerName, listeners)
    	if vo == nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 24.7K bytes
    - Viewed (0)
  4. plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go

    				rbacv1helpers.NewRule("patch", "update").Groups(networkingGroup).Resources("servicecidrs/status").RuleOrDie(),
    				rbacv1helpers.NewRule("get", "list", "watch").Groups(networkingGroup).Resources("ipaddresses").RuleOrDie(),
    				eventsRule(),
    			},
    		})
    	}
    	addControllerRole(&controllerRoles, &controllerRoleBindings, func() rbacv1.ClusterRole {
    		role := rbacv1.ClusterRole{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 19:25:10 UTC 2024
    - 28.9K bytes
    - Viewed (0)
  5. pilot/pkg/xds/ads.go

    }
    
    func (s *DiscoveryServer) ProxyUpdate(clusterID cluster.ID, ip string) {
    	var connection *Connection
    
    	for _, v := range s.Clients() {
    		if v.proxy.Metadata.ClusterID == clusterID && v.proxy.IPAddresses[0] == ip {
    			connection = v
    			break
    		}
    	}
    
    	// It is possible that the envoy has not connected to this pilot, maybe connected to another pilot
    	if connection == nil {
    		return
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  6. api/openapi-spec/v3/apis__networking.k8s.io__v1alpha1_openapi.json

    {
      "components": {
        "schemas": {
          "io.k8s.api.networking.v1alpha1.IPAddress": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 08 04:18:56 UTC 2024
    - 196.5K bytes
    - Viewed (0)
  7. pilot/pkg/networking/core/cluster_builder.go

    		sendHbone:          features.EnableHBONESend || proxy.IsWaypointProxy(),
    		locality:           proxy.Locality,
    		proxyLabels:        proxy.Labels,
    		proxyView:          proxy.GetView(),
    		proxyIPAddresses:   proxy.IPAddresses,
    		configNamespace:    proxy.ConfigNamespace,
    		req:                req,
    		cache:              cache,
    	}
    	if proxy.Metadata != nil {
    		if proxy.Metadata.TLSClientCertChain != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 31.6K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/sidecar_simulation_test.go

    			Service:     svc,
    			ServicePort: p,
    			Endpoint: &model.IstioEndpoint{
    				Address:         proxy.IPAddresses[0],
    				ServicePortName: p.Name,
    				EndpointPort:    uint32(targetPort),
    			},
    		})
    	}
    	return ret
    }
    
    func TestInboundClusters(t *testing.T) {
    	proxy := &model.Proxy{
    		IPAddresses: []string{"1.2.3.4"},
    		Metadata:    &model.NodeMetadata{},
    	}
    	service := &model.Service{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    		BasicConstraintsValid: true,
    	}
    
    	hosts := strings.Split(host, ",")
    	for _, h := range hosts {
    		if ip := net.ParseIP(h); ip != nil {
    			template.IPAddresses = append(template.IPAddresses, ip)
    		} else {
    			template.DNSNames = append(template.DNSNames, h)
    		}
    	}
    
    	template.IsCA = true
    	template.KeyUsage |= x509.KeyUsageCertSign
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:50:49 UTC 2024
    - 76.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test_cases/invalid/gateway/invalid-addresses.yaml

    kind: Gateway
    metadata:
      name: invalid-addresses
    spec:
      gatewayClassName: acme-lb
      addresses:
      - value: 1200:0000:::AB00:1234:0000:2552:7777:1313
      - value: 21DA:D3:0:2F3B:2AY:FF:FE28:9C5A
      - value: "2001:db8:3c4d:15:0:d234:3eee:"
      - value: "2001:db8:3c4d:15:0:d234:3eee:::"
      - value: ":::1234::"
      - value: "1.1.1"
      - value: "1.a.3.4"
      - value: "foo.com"
      - type: IPAddress
        value: "256.255.255.255"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Oct 27 17:15:18 UTC 2023
    - 686 bytes
    - Viewed (0)
Back to top