Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 31 for internalTrafficPolicy (0.74 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pkg/apis/core/validation/validation_test.go

    			// that may have allowed internalTrafficPolicy when Type=ExternalName.
    			// This test case ensures we don't break compatibility for internalTrafficPolicy
    			// when Type=ExternalName
    			name: "internalTrafficPolicy field is set when type is ExternalName",
    			tweakSvc: func(s *core.Service) {
    				cluster := core.ServiceInternalTrafficPolicyCluster
    				s.Spec.InternalTrafficPolicy = &cluster
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 857.7K bytes
    - Viewed (0)
  6. pkg/apis/core/validation/validation.go

    			allErrs = append(allErrs, field.Required(field.NewPath("spec").Child("internalTrafficPolicy"), ""))
    		}
    	}
    
    	if service.Spec.InternalTrafficPolicy != nil && !supportedServiceInternalTrafficPolicy.Has(*service.Spec.InternalTrafficPolicy) {
    		allErrs = append(allErrs, field.NotSupported(field.NewPath("spec").Child("internalTrafficPolicy"), *service.Spec.InternalTrafficPolicy, sets.List(supportedServiceInternalTrafficPolicy)))
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 349.5K bytes
    - Viewed (0)
  7. pkg/registry/core/service/storage/storage_test.go

    				t.Errorf("ipFamilies: expected %v, got %v", want, got)
    			}
    			if want, got := fmtInternalTrafficPolicy(exp.Spec.InternalTrafficPolicy), fmtInternalTrafficPolicy(svc.Spec.InternalTrafficPolicy); want != got {
    				t.Errorf("internalTrafficPolicy: expected %v, got %v", want, got)
    			}
    		})
    	}
    }
    
    //
    // Scaffolding for create-update-delete tests.  Many tests can and should be
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 440.2K bytes
    - Viewed (0)
  8. 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)
  9. pkg/proxy/nftables/proxier.go

    			internalTrafficFilterVerdict = fmt.Sprintf("goto %s", rejectChain)
    			externalTrafficFilterVerdict = fmt.Sprintf("goto %s", rejectChain)
    		} else {
    			if !hasInternalEndpoints {
    				// The internalTrafficPolicy is "Local" but there are no local
    				// endpoints. Traffic to the clusterIP will be dropped, but
    				// external traffic may still be accepted.
    				internalTrafficFilterVerdict = "drop"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  10. pkg/proxy/iptables/proxier.go

    			externalTrafficFilterTarget = "REJECT"
    			externalTrafficFilterComment = internalTrafficFilterComment
    		} else {
    			if !hasInternalEndpoints {
    				// The internalTrafficPolicy is "Local" but there are no local
    				// endpoints. Traffic to the clusterIP will be dropped, but
    				// external traffic may still be accepted.
    				internalTrafficFilterTarget = "DROP"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
Back to top