Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 45 for internalTrafficPolicy (0.31 sec)

  1. pkg/proxy/topology_test.go

    	}, {
    		name:             "internalTrafficPolicy: Local, with empty endpoints",
    		serviceInfo:      &BaseServicePortInfo{internalPolicyLocal: true},
    		endpoints:        []Endpoint{},
    		clusterEndpoints: nil,
    		localEndpoints:   sets.New[string](),
    	}, {
    		name:        "internalTrafficPolicy: Local, but all endpoints are remote",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 26.6K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/conversion.go

    		externalName = svc.Spec.ExternalName
    		if features.EnableExternalNameAlias {
    			resolution = model.Alias
    		} else {
    			resolution = model.DNSLB
    		}
    	}
    	if svc.Spec.InternalTrafficPolicy != nil && *svc.Spec.InternalTrafficPolicy == corev1.ServiceInternalTrafficPolicyLocal {
    		nodeLocal = true
    	}
    
    	if svc.Spec.ClusterIP == corev1.ClusterIPNone { // headless services should not be load balanced
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 9.4K bytes
    - Viewed (0)
  3. pkg/proxy/ipvs/proxier_test.go

    				Selector:  map[string]string{"foo": "bar"},
    				Ports:     []v1.ServicePort{{Name: "", TargetPort: intstr.FromInt32(80), Protocol: v1.ProtocolTCP}},
    			},
    		}
    		if tc.internalTrafficPolicy != nil {
    			svc.Spec.InternalTrafficPolicy = tc.internalTrafficPolicy
    		}
    
    		fp.OnServiceAdd(svc)
    
    		// Add initial endpoint slice
    		endpointSlice := &discovery.EndpointSlice{
    			ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 01:31:57 UTC 2024
    - 186.8K bytes
    - Viewed (0)
  4. pkg/proxy/iptables/proxier_test.go

    					Selector:  map[string]string{"foo": "bar"},
    					Ports:     []v1.ServicePort{{Name: "", Port: 80, Protocol: v1.ProtocolTCP}},
    				},
    			}
    			if tc.internalTrafficPolicy != nil {
    				svc.Spec.InternalTrafficPolicy = tc.internalTrafficPolicy
    			}
    
    			fp.OnServiceAdd(svc)
    
    			endpointSlice := &discovery.EndpointSlice{
    				ObjectMeta: metav1.ObjectMeta{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 249.9K bytes
    - Viewed (0)
  5. pkg/apis/core/v1/defaults_test.go

    			name:                          "must set default internalTrafficPolicy",
    			expectedInternalTrafficPolicy: &cluster,
    			svc:                           v1.Service{},
    		},
    		{
    			name:                          "must not set default internalTrafficPolicy when it's cluster",
    			expectedInternalTrafficPolicy: &cluster,
    			svc: v1.Service{
    				Spec: v1.ServiceSpec{
    					InternalTrafficPolicy: &cluster,
    				},
    			},
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 84.4K bytes
    - Viewed (0)
  6. pkg/apis/core/v1/defaults.go

    	}
    
    	if obj.Spec.InternalTrafficPolicy == nil {
    		if obj.Spec.Type == v1.ServiceTypeNodePort || obj.Spec.Type == v1.ServiceTypeLoadBalancer || obj.Spec.Type == v1.ServiceTypeClusterIP {
    			serviceInternalTrafficPolicyCluster := v1.ServiceInternalTrafficPolicyCluster
    			obj.Spec.InternalTrafficPolicy = &serviceInternalTrafficPolicyCluster
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 19 22:24:15 UTC 2024
    - 14.8K bytes
    - Viewed (0)
  7. pilot/pkg/serviceregistry/kube/controller/ambient/services.go

    				workloadapi.LoadBalancing_REGION,
    				workloadapi.LoadBalancing_ZONE,
    				workloadapi.LoadBalancing_SUBZONE,
    			},
    			Mode: workloadapi.LoadBalancing_FAILOVER,
    		}
    	}
    	if itp := svc.Spec.InternalTrafficPolicy; itp != nil && *itp == v1.ServiceInternalTrafficPolicyLocal {
    		lb = &workloadapi.LoadBalancing{
    			// Only allow endpoints on the same node.
    			RoutingPreference: []workloadapi.LoadBalancing_Scope{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 12:29:55 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  8. pkg/registry/core/service/storage/storage.go

    	normalizeClusterIPs(After{service}, Before{nil})
    
    	// Set ipFamilies and ipFamilyPolicy if needed.
    	r.defaultOnReadIPFamilies(service)
    
    	// We unintentionally defaulted internalTrafficPolicy when it's not needed
    	// for the ExternalName type. It's too late to change the field in storage,
    	// but we can drop the field when read.
    	defaultOnReadInternalTrafficPolicy(service)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 11 13:09:33 UTC 2024
    - 22.3K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/kube/conversion_test.go

    			Namespace: namespace,
    		},
    		Spec: corev1.ServiceSpec{
    			Ports: []corev1.ServicePort{
    				{
    					Name:     "http",
    					Port:     80,
    					Protocol: corev1.ProtocolTCP,
    				},
    			},
    			InternalTrafficPolicy: &local,
    		},
    	}
    
    	service := ConvertService(svc, domainSuffix, clusterID, nil)
    	if service == nil {
    		t.Fatalf("could not convert service")
    	}
    
    	if !service.Attributes.NodeLocal {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  10. pkg/proxy/winkernel/proxier.go

    	localTrafficDSR := service.Spec.ExternalTrafficPolicy == v1.ServiceExternalTrafficPolicyLocal
    	var internalTrafficLocal bool
    	if service.Spec.InternalTrafficPolicy != nil {
    		internalTrafficLocal = *service.Spec.InternalTrafficPolicy == v1.ServiceInternalTrafficPolicyLocal
    	}
    	hcnImpl := proxier.hcn
    	err := hcnImpl.DsrSupported()
    	if err != nil {
    		preserveDIP = false
    		localTrafficDSR = false
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
Back to top