- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 64 for addressType (0.22 sec)
-
staging/src/k8s.io/api/discovery/v1beta1/generated.pb.go
} func (m *EndpointSlice) MarshalToSizedBuffer(dAtA []byte) (int, error) { i := len(dAtA) _ = i var l int _ = l i -= len(m.AddressType) copy(dAtA[i:], m.AddressType) i = encodeVarintGenerated(dAtA, i, uint64(len(m.AddressType))) i-- dAtA[i] = 0x22 if len(m.Ports) > 0 { for iNdEx := len(m.Ports) - 1; iNdEx >= 0; iNdEx-- { {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:37 UTC 2024 - 54.2K bytes - Viewed (0) -
tests/integration/pilot/gateway_conformance_test.go
Insert(features.HTTPRouteExtendedFeatures.UnsortedList()...). Insert(features.MeshCoreFeatures.UnsortedList()...). Insert(features.GRPCRouteCoreFeatures.UnsortedList()...) } hostnameType := v1.AddressType("Hostname") istioVersion, _ := env.ReadVersion() opts := suite.ConformanceOptions{ Client: c, Clientset: gatewayConformanceInputs.Client.Kube(),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 15:22:47 UTC 2024 - 5.7K bytes - Viewed (0) -
tests/integration/ambient/gateway_conformance_test.go
c, err := client.New(gatewayConformanceInputs.Client.RESTConfig(), client.Options{ Scheme: kube.IstioScheme, Mapper: mapper, }) if err != nil { t.Fatal(err) } hostnameType := v1.AddressType("Hostname") istioVersion, _ := env.ReadVersion() supported := gateway.SupportedFeatures.Clone().Delete(gwfeatures.SupportMeshConsumerRoute) opts := suite.ConformanceOptions{ Client: c,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 02 21:29:40 UTC 2024 - 6K bytes - Viewed (0) -
pilot/pkg/xds/workload.go
resources = append(resources, &discovery.Resource{ Name: n, Aliases: aliases, Resource: protoconv.MessageToAny(addr.GetWorkload()), // TODO: pre-marshal }) } case v3.AddressType: resources = append(resources, &discovery.Resource{ Name: n, Aliases: aliases, Resource: protoconv.MessageToAny(addr), // TODO: pre-marshal }) } } if full {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 14:14:30 UTC 2024 - 8.7K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/conversion_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 20:24:52 UTC 2024 - 34.9K bytes - Viewed (0) -
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)