Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for createProxies (0.2 sec)

  1. pilot/pkg/xds/discovery_test.go

    	"google.golang.org/grpc"
    
    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pkg/config/schema/kind"
    	"istio.io/istio/pkg/test/util/retry"
    	"istio.io/istio/pkg/util/sets"
    )
    
    func createProxies(n int) []*Connection {
    	proxies := make([]*Connection, 0, n)
    	for p := 0; p < n; p++ {
    		conn := newConnection("", &fakeStream{})
    		conn.SetID(fmt.Sprintf("proxy-%v", p))
    		proxies = append(proxies, conn)
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 9.2K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_other.go

    func (s *ProxyServer) platformCheckSupported(ctx context.Context) (ipv4Supported, ipv6Supported, dualStackSupported bool, err error) {
    	return false, false, false, unsupportedError
    }
    
    // createProxier creates the proxy.Provider
    func (s *ProxyServer) createProxier(ctx context.Context, config *proxyconfigapi.KubeProxyConfiguration, dualStackMode, initOnly bool) (proxy.Provider, error) {
    	return nil, unsupportedError
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 22 05:08:41 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  3. cmd/kube-proxy/app/server_windows.go

    	ipv6Supported = true
    
    	compatTester := winkernel.DualStackCompatTester{}
    	dualStackSupported = compatTester.DualStackCompatible(s.Config.Winkernel.NetworkName)
    
    	return
    }
    
    // createProxier creates the proxy.Provider
    func (s *ProxyServer) createProxier(ctx context.Context, config *proxyconfigapi.KubeProxyConfiguration, dualStackMode, initOnly bool) (proxy.Provider, error) {
    	if initOnly {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  4. cmd/kube-proxy/app/server_linux.go

    	}
    
    	// The Linux proxies can always support dual-stack if they can support both IPv4
    	// and IPv6.
    	dualStackSupported = ipv4Supported && ipv6Supported
    	return
    }
    
    // createProxier creates the proxy.Provider
    func (s *ProxyServer) createProxier(ctx context.Context, config *proxyconfigapi.KubeProxyConfiguration, dualStack, initOnly bool) (proxy.Provider, error) {
    	logger := klog.FromContext(ctx)
    	var proxier proxy.Provider
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 08 13:48:54 UTC 2024
    - 18.1K bytes
    - Viewed (0)
  5. cmd/kube-proxy/app/server_linux_test.go

    					v1.IPv4Protocol: netutils.ParseIPSloppy("127.0.0.1"),
    					v1.IPv6Protocol: net.IPv6zero,
    				},
    			}
    			err := s.platformSetup(ctx)
    			if err != nil {
    				t.Errorf("ProxyServer.createProxier() error = %v", err)
    				return
    			}
    			if !reflect.DeepEqual(s.podCIDRs, tt.wantPodCIDRs) {
    				t.Errorf("Expected PodCIDRs %v got %v", tt.wantPodCIDRs, s.podCIDRs)
    			}
    
    		})
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Apr 28 15:51:23 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  6. cmd/kube-proxy/app/server.go

    		if fatal {
    			return nil, fmt.Errorf("kube-proxy configuration is incorrect: %v", err)
    		}
    		logger.Error(err, "Kube-proxy configuration may be incomplete or incorrect")
    	}
    
    	s.Proxier, err = s.createProxier(ctx, config, dualStackSupported, initOnly)
    	if err != nil {
    		return nil, err
    	}
    
    	return s, nil
    }
    
    // checkBadConfig checks for bad/deprecated configuation
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 46.8K bytes
    - Viewed (0)
Back to top