- Sort Score
- Result 10 results
- Languages All
Results 21 - 26 of 26 for addressTypes (0.96 sec)
-
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) -
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) -
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) -
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) -
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) -
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)