- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 83 for addressTypes (0.18 sec)
-
android/guava/src/com/google/common/net/InetAddresses.java
int numBytes = isIpv6 ? 16 : 4; byte[] addressBytes = address.toByteArray(); byte[] targetCopyArray = new byte[numBytes]; int srcPos = Math.max(0, addressBytes.length - numBytes); int copyLength = addressBytes.length - srcPos; int destPos = numBytes - copyLength; // Check the extra bytes in the BigInteger are all zero.
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 24 16:44:05 UTC 2024 - 47.1K 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) -
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) -
pkg/proxy/endpointschangetracker_test.go
Name: fmt.Sprintf("%s-%d", name, slice), Namespace: namespace, Annotations: map[string]string{}, Labels: map[string]string{ discovery.LabelServiceName: name, }, }, AddressType: discovery.AddressTypeIPv4, } epsFunc(eps) return eps } func TestUpdateEndpointsMap(t *testing.T) { emptyEndpoint := func(eps *discovery.EndpointSlice) { eps.Endpoints = []discovery.Endpoint{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 79.9K bytes - Viewed (0)