- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for NetworkName (0.29 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)