- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 941 for ipaddresses (0.17 sec)
-
pilot/pkg/serviceregistry/kube/controller/controller.go
// To tackle this, we need a ip2instance map like what we have in service entry. func (c *Controller) GetProxyServiceTargets(proxy *model.Proxy) []model.ServiceTarget { if len(proxy.IPAddresses) > 0 { proxyIP := proxy.IPAddresses[0] // look up for a WorkloadEntry; if there are multiple WorkloadEntry(s) // with the same IP, choose one deterministically
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pkg/util/iptree/iptree.go
// prefixContainIP returns true if the given IP is contained with the prefix, // is not the network address and also, if IPv4, is not the broadcast address. // This is required because the Kubernetes allocators reserve these addresses // so IPAddresses can not block deletion of this ranges. func prefixContainIP(prefix netip.Prefix, ip netip.Addr) bool { // if the IP is the network address is not contained if prefix.Masked().Addr() == ip { return false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17.7K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_builder_test.go
test.SetForTest(t, &features.EnableAdditionalIpv4OutboundListenerForIpv6Only, true) cg := NewConfigGenTest(t, TestOptions{Services: testServices}) proxy := cg.SetupProxy(&model.Proxy{IPAddresses: []string{"1111:2222::1"}}) listeners := buildListeners(t, TestOptions{Services: testServices}, proxy) vo := xdstest.ExtractListener(model.VirtualOutboundListenerName, listeners) if vo == nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 24.7K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go
rbacv1helpers.NewRule("patch", "update").Groups(networkingGroup).Resources("servicecidrs/status").RuleOrDie(), rbacv1helpers.NewRule("get", "list", "watch").Groups(networkingGroup).Resources("ipaddresses").RuleOrDie(), eventsRule(), }, }) } addControllerRole(&controllerRoles, &controllerRoleBindings, func() rbacv1.ClusterRole { role := rbacv1.ClusterRole{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 28.9K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
} func (s *DiscoveryServer) ProxyUpdate(clusterID cluster.ID, ip string) { var connection *Connection for _, v := range s.Clients() { if v.proxy.Metadata.ClusterID == clusterID && v.proxy.IPAddresses[0] == ip { connection = v break } } // It is possible that the envoy has not connected to this pilot, maybe connected to another pilot if connection == nil { return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
api/openapi-spec/v3/apis__networking.k8s.io__v1alpha1_openapi.json
{ "components": { "schemas": { "io.k8s.api.networking.v1alpha1.IPAddress": {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 04:18:56 UTC 2024 - 196.5K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
sendHbone: features.EnableHBONESend || proxy.IsWaypointProxy(), locality: proxy.Locality, proxyLabels: proxy.Labels, proxyView: proxy.GetView(), proxyIPAddresses: proxy.IPAddresses, configNamespace: proxy.ConfigNamespace, req: req, cache: cache, } if proxy.Metadata != nil { if proxy.Metadata.TLSClientCertChain != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/core/sidecar_simulation_test.go
Service: svc, ServicePort: p, Endpoint: &model.IstioEndpoint{ Address: proxy.IPAddresses[0], ServicePortName: p.Name, EndpointPort: uint32(targetPort), }, }) } return ret } func TestInboundClusters(t *testing.T) { proxy := &model.Proxy{ IPAddresses: []string{"1.2.3.4"}, Metadata: &model.NodeMetadata{}, } service := &model.Service{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 84.7K bytes - Viewed (0) -
cmd/test-utils_test.go
BasicConstraintsValid: true, } hosts := strings.Split(host, ",") for _, h := range hosts { if ip := net.ParseIP(h); ip != nil { template.IPAddresses = append(template.IPAddresses, ip) } else { template.DNSNames = append(template.DNSNames, h) } } template.IsCA = true template.KeyUsage |= x509.KeyUsageCertSign
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:50:49 UTC 2024 - 76.9K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/ratcheting_test_cases/invalid/gateway/invalid-addresses.yaml
kind: Gateway metadata: name: invalid-addresses spec: gatewayClassName: acme-lb addresses: - value: 1200:0000:::AB00:1234:0000:2552:7777:1313 - value: 21DA:D3:0:2F3B:2AY:FF:FE28:9C5A - value: "2001:db8:3c4d:15:0:d234:3eee:" - value: "2001:db8:3c4d:15:0:d234:3eee:::" - value: ":::1234::" - value: "1.1.1" - value: "1.a.3.4" - value: "foo.com" - type: IPAddress value: "256.255.255.255"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 17:15:18 UTC 2023 - 686 bytes - Viewed (0)