- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for addressType (0.19 sec)
-
pkg/kubelet/nodestatus/setters.go
{Type: v1.NodeHostName, Address: hostname}, } } return nil } } func hasAddressType(addresses []v1.NodeAddress, addressType v1.NodeAddressType) bool { for _, address := range addresses { if address.Type == addressType { return true } } return false } func hasAddressValue(addresses []v1.NodeAddress, addressValue string) bool { for _, address := range addresses {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0) -
pkg/proxy/iptables/number_generated_rules_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller_test.go
}, Spec: k8s.GatewaySpec{ GatewayClassName: k8s.ObjectName(features.GatewayAPIDefaultGatewayClass), Addresses: []k8s.GatewayAddress{{ Type: func() *k8s.AddressType { x := k8s.IPAddressType; return &x }(), Value: "1.2.3.4", }}, }, }, objects: defaultObjects, discoveryNamespaceFilter: discoveryNamespacesFilter, }, {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 16.5K bytes - Viewed (0) -
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)