Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 26 of 26 for addressTypes (0.96 sec)

  1. pilot/pkg/xds/delta_test.go

    	s.MemRegistry.AddServiceInfo(svcA, svcB, svcC)
    
    	// Wait until the above debounce, to ensure we can precisely check XDS responses without spurious pushes
    	s.EnsureSynced(t)
    
    	ads := s.ConnectDeltaADS().WithType(v3.AddressType).WithID("ztunnel~1.1.1.1~test.default~default.svc.cluster.local")
    	ads.Request(&discovery.DeltaDiscoveryRequest{
    		ResourceNamesSubscribe: []string{"*"},
    	})
    	resp := ads.ExpectResponse()
    	if len(resp.Resources) != 6 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 15.2K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/endpointslice.go

    	}
    
    	return model.UnHealthy
    }
    
    func (esc *endpointSliceController) updateEndpointCacheForSlice(hostName host.Name, slice *v1.EndpointSlice) {
    	var endpoints []*model.IstioEndpoint
    	if slice.AddressType == v1.AddressTypeFQDN {
    		// TODO(https://github.com/istio/istio/issues/34995) support FQDN endpointslice
    		return
    	}
    	svc := esc.c.GetService(hostName)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 16.9K bytes
    - Viewed (0)
  3. pkg/proxy/endpointslicecache_test.go

    			Name:      fmt.Sprintf("%s-%d", serviceName, sliceNum),
    			Namespace: namespace,
    			Labels:    map[string]string{discovery.LabelServiceName: serviceName},
    		},
    		Ports:       []discovery.EndpointPort{},
    		AddressType: discovery.AddressTypeIPv4,
    		Endpoints:   []discovery.Endpoint{},
    	}
    
    	for i, portNum := range portNums {
    		endpointSlice.Ports = append(endpointSlice.Ports, discovery.EndpointPort{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 21:07:21 UTC 2024
    - 24.9K bytes
    - Viewed (0)
  4. pilot/pkg/xds/ads.go

    // order after the types listed here
    var PushOrder = []string{
    	v3.ClusterType,
    	v3.EndpointType,
    	v3.ListenerType,
    	v3.RouteType,
    	v3.SecretType,
    	v3.AddressType,
    	v3.WorkloadType,
    	v3.WorkloadAuthorizationType,
    }
    
    // KnownOrderedTypeUrls has typeUrls for which we know the order of push.
    var KnownOrderedTypeUrls = sets.New(PushOrder...)
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. pilot/pkg/xds/delta.go

    // This is used when resources are spontaneously pushed during Delta XDS
    func requiresResourceNamesModification(url string) bool {
    	return url == v3.AddressType || url == v3.WorkloadType
    }
    
    // neverRemoveDelta checks if a type should never remove resources
    func neverRemoveDelta(url string) bool {
    	// https://github.com/envoyproxy/envoy/issues/32823
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  6. pilot/pkg/xds/debug.go

    			}
    		}
    		writeJSON(w, configDump, req)
    		return
    	}
    
    	if con.proxy.IsZTunnel() {
    		resources := s.getConfigDumpByResourceType(con, nil, []string{v3.AddressType})
    		configDump := &admin.ConfigDump{}
    		for _, resource := range resources {
    			for _, rr := range resource {
    				configDump.Configs = append(configDump.Configs, rr.Resource)
    			}
    		}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
Back to top