Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 23 for NetworkName (0.29 sec)

  1. tests/integration/telemetry/tracing/zipkin/server_tracing_test.go

    func TestServerTracing(t *testing.T) {
    	framework.NewTest(t).
    		Run(func(t framework.TestContext) {
    			appNsInst := tracing.GetAppNamespace()
    			for _, cluster := range t.Clusters().ByNetwork()[t.Clusters().Default().NetworkName()] {
    				t.NewSubTest(cluster.StableName()).Run(func(t framework.TestContext) {
    					retry.UntilSuccessOrFail(t, func() error {
    						err := tracing.SendTraffic(t, nil, cluster)
    						if err != nil {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  2. cmd/kube-proxy/app/server_windows.go

    	// not support dual-stack.
    	ipv4Supported = true
    	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) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 26 13:27:41 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  3. pkg/proxy/winkernel/proxier.go

    		return false
    	}
    
    	// check if network is using overlay
    	hns, _ := newHostNetworkService(hcnImpl)
    	networkName, err := getNetworkName(networkName)
    	if err != nil {
    		klog.ErrorS(err, "Unable to determine dual-stack status, falling back to single-stack")
    		return false
    	}
    	networkInfo, err := getNetworkInfo(hns, networkName)
    	if err != nil {
    		klog.ErrorS(err, "Unable to determine dual-stack status, falling back to single-stack")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  4. tests/integration/telemetry/tracing/otelcollector/tracing_test.go

    						// TODO fix tracing tests in multi-network https://github.com/istio/istio/issues/28890
    						for _, cluster := range ctx.Clusters().ByNetwork()[ctx.Clusters().Default().NetworkName()] {
    							cluster := cluster
    							ctx.NewSubTest(cluster.StableName()).Run(func(ctx framework.TestContext) {
    								retry.UntilSuccessOrFail(ctx, func() error {
    									err := tracing.SendTraffic(ctx, nil, cluster)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 22:56:30 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  5. pkg/test/framework/components/echo/match/matchers.go

    		return c.Name() == i.Config().Cluster.Name()
    	}
    }
    
    // Network matches instances deployed in the given network.
    func Network(n string) Matcher {
    	return func(i echo.Instance) bool {
    		return i.Config().Cluster.NetworkName() == n
    	}
    }
    
    // VM matches instances with DeployAsVM
    var VM Matcher = func(i echo.Instance) bool {
    	return i.Config().IsVM()
    }
    
    // NotVM is matches against instances that are NOT VMs.
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  6. pkg/proxy/apis/config/types.go

    }
    
    // KubeProxyWinkernelConfiguration contains Windows/HNS settings for
    // the Kubernetes proxy server.
    type KubeProxyWinkernelConfiguration struct {
    	// networkName is the name of the network kube-proxy will use
    	// to create endpoints and policies
    	NetworkName string
    	// sourceVip is the IP address of the source VIP endpoint used for
    	// NAT when loadbalancing
    	SourceVip string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 13K bytes
    - Viewed (0)
  7. pkg/test/framework/components/istio/kube.go

    			"values.global.variant=" + ctx.Settings().Image.Variant,
    		},
    	}
    
    	if ctx.Environment().IsMultiNetwork() && c.NetworkName() != "" {
    		args.AppendSet("values.global.meshID", meshID)
    		args.AppendSet("values.global.network", c.NetworkName())
    	}
    
    	// Include all user-specified values and configuration options.
    	if cfg.EnableCNI {
    		args.AppendSet("components.cni.enabled", "true")
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 22:12:34 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  8. operator/pkg/helmreconciler/reconciler.go

    }
    
    // Reconcile reconciles the associated resources.
    func (h *HelmReconciler) Reconcile() (*v1alpha1.InstallStatus, error) {
    	if err := util.CreateNamespace(h.kubeClient.Kube(), istioV1Alpha1.Namespace(h.iop.Spec), h.networkName(), h.opts.DryRun); err != nil {
    		return nil, err
    	}
    	manifestMap, err := h.RenderCharts()
    	if err != nil {
    		return nil, err
    	}
    
    	err = h.analyzeWebhooks(manifestMap[name.PilotComponentName])
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Feb 22 08:32:23 UTC 2024
    - 22K bytes
    - Viewed (0)
  9. pkg/test/framework/components/echo/kube/deployment.go

    			d.cfg.Service,
    			err)
    	}
    }
    
    func (d *deployment) workloadEntryYAML(w *workload) string {
    	name := w.pod.Name
    	podIP := w.pod.Status.PodIP
    	sa := serviceAccount(d.cfg)
    	network := d.cfg.Cluster.NetworkName()
    	service := d.cfg.Service
    	version := w.pod.Labels[constants.TestVMVersionLabel]
    
    	return fmt.Sprintf(`
    apiVersion: networking.istio.io/v1alpha3
    kind: WorkloadEntry
    metadata:
      name: %s
    spec:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 09 12:26:52 UTC 2024
    - 24.1K bytes
    - Viewed (0)
  10. tests/integration/security/reachability_test.go

    											}
    										} else if c.expectCrossCluster(from, opts) {
    											// Expect to stay in the same network as the source pod.
    											expectedClusters := to.Clusters().ForNetworks(from.Config().Cluster.NetworkName())
    											if !check.IsDNSCaptureEnabled(t) && opts.To.Config().Headless {
    												opts.Check = check.And(opts.Check, check.ReachedSourceCluster(t.Clusters()))
    											} else {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 20.6K bytes
    - Viewed (0)
Back to top