Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for internalTrafficPolicy (0.55 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. 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)
  3. 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)
  4. 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)
  5. pkg/registry/core/service/strategy_test.go

    			},
    			ClusterIP:             "1.2.3.4",
    			ClusterIPs:            []string{"1.2.3.4", "5:6:7::8"},
    			IPFamilyPolicy:        &preferDual,
    			IPFamilies:            []api.IPFamily{"IPv4", "IPv6"},
    			InternalTrafficPolicy: &clusterInternalTrafficPolicy,
    		},
    	}
    }
    
    func makeValidServicePort(name string, proto api.Protocol, port int32) api.ServicePort {
    	return api.ServicePort{
    		Name:       name,
    		Protocol:   proto,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 32.4K bytes
    - Viewed (0)
  6. pilot/pkg/model/service.go

    	// spec.Type
    	Type string
    
    	// spec.ExternalName
    	ExternalName string
    
    	// NodeLocal means the proxy will only forward traffic to node local endpoints
    	// spec.InternalTrafficPolicy == Local
    	NodeLocal bool
    }
    
    // DeepCopy creates a deep copy of ServiceAttributes, but skips internal mutexes.
    func (s *ServiceAttributes) DeepCopy() ServiceAttributes {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 02:03:58 UTC 2024
    - 46.3K bytes
    - Viewed (0)
Back to top