- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for createProxies (0.17 sec)
-
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) -
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) -
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) -
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) -
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) -
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)