Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for internalTrafficPolicy (0.27 sec)

  1. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Service.json

    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 2.9K bytes
    - Viewed (0)
  2. staging/src/k8s.io/api/testdata/v1.30.0/core.v1.Service.yaml

      clusterIPs:
      - clusterIPsValue
      externalIPs:
      - externalIPsValue
      externalName: externalNameValue
      externalTrafficPolicy: externalTrafficPolicyValue
      healthCheckNodePort: 12
      internalTrafficPolicy: internalTrafficPolicyValue
      ipFamilies:
      - ipFamiliesValue
      ipFamilyPolicy: ipFamilyPolicyValue
      loadBalancerClass: loadBalancerClassValue
      loadBalancerIP: loadBalancerIPValue
      loadBalancerSourceRanges:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 08:52:25 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  3. pkg/proxy/nftables/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: Sat Apr 27 01:31:57 UTC 2024
    - 173.5K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top