Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for IsImplemented (0.16 sec)

  1. pkg/proxy/util/localdetector_test.go

    */
    
    package util
    
    import (
    	"reflect"
    	"testing"
    )
    
    func TestNoOpLocalDetector(t *testing.T) {
    	localDetector := NewNoOpLocalDetector()
    	if localDetector.IsImplemented() {
    		t.Error("NoOpLocalDetector returns true for IsImplemented")
    	}
    
    	ifLocal := localDetector.IfLocal()
    	if len(ifLocal) != 0 {
    		t.Errorf("NoOpLocalDetector returns %v for IsLocal (expected nil)", ifLocal)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 15:34:37 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. pkg/proxy/util/localdetector.go

    )
    
    // LocalTrafficDetector generates iptables or nftables rules to detect traffic from local pods.
    type LocalTrafficDetector interface {
    	// IsImplemented returns true if the implementation does something, false
    	// otherwise. You should not call the other methods if IsImplemented() returns
    	// false.
    	IsImplemented() bool
    
    	// IfLocal returns iptables arguments that will match traffic from a local pod.
    	IfLocal() []string
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 15:34:37 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  3. cmd/kube-proxy/app/server_linux.go

    		for family, cidrs := range proxyutil.MapCIDRsByIPFamily(clusterCIDRs) {
    			localDetectors[family] = proxyutil.NewDetectLocalByCIDR(cidrs[0].String())
    		}
    		if !localDetectors[primaryIPFamily].IsImplemented() {
    			logger.Info("Detect-local-mode set to ClusterCIDR, but no cluster CIDR specified for primary IP family", "ipFamily", primaryIPFamily, "clusterCIDR", config.ClusterCIDR)
    		}
    
    	case proxyconfigapi.LocalModeNodeCIDR:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  4. pkg/proxy/nftables/proxier.go

    					Rule: knftables.Concat(
    						ipX, "daddr", svcInfo.ClusterIP(),
    						protocol, "dport", svcInfo.Port(),
    						"jump", markMasqChain,
    					),
    				})
    			} else if proxier.localDetector.IsImplemented() {
    				// This masquerades off-cluster traffic to a service VIP. The
    				// idea is that you can establish a static route for your
    				// Service range, routing to any node, and that node will
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  5. pkg/proxy/iptables/proxier.go

    			)
    			if proxier.masqueradeAll {
    				natRules.Write(
    					"-A", string(internalTrafficChain),
    					args,
    					"-j", string(kubeMarkMasqChain))
    			} else if proxier.localDetector.IsImplemented() {
    				// This masquerades off-cluster traffic to a service VIP. The
    				// idea is that you can establish a static route for your
    				// Service range, routing to any node, and that node will
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 21 14:39:54 UTC 2024
    - 65.1K bytes
    - Viewed (0)
  6. pkg/proxy/ipvs/proxier.go

    		)
    		if proxier.masqueradeAll {
    			proxier.natRules.Write(
    				args, "dst,dst",
    				"-j", string(kubeMarkMasqChain))
    		} else if proxier.localDetector.IsImplemented() {
    			// This masquerades off-cluster traffic to a service VIP.  The idea
    			// is that you can establish a static route for your Service range,
    			// routing to any node, and that node will bridge into the Service
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 77.7K bytes
    - Viewed (0)
Back to top