- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for NetworkName (0.17 sec)
-
pkg/test/framework/components/cluster/clusters.go
return out } // ByNetwork returns a map of network name to a subset of clusters func (c Clusters) ByNetwork() ClustersByNetwork { out := make(ClustersByNetwork) for _, cc := range c { out[cc.NetworkName()] = append(out[cc.NetworkName()], cc) } return out } // Networks returns the list of network names for the clusters. func (c Clusters) Networks() []string { return c.ByNetwork().Networks() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pkg/test/framework/components/cluster/topology.go
// MetadataValue provides the configured value for a metadata key in the cluster configuration. func (c Topology) MetadataValue(key string) string { return c.ConfigMetadata.String(key) } // NetworkName the cluster is on func (c Topology) NetworkName() string { return c.Network } // Name provides the ClusterName this cluster used by Istio. func (c Topology) Name() string { return c.ClusterName }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.5K bytes - Viewed (0) -
pkg/test/framework/components/cluster/cluster.go
// allow test grid to compare runs, even when the underlying cluster names are dynamic. // Use Name for validation/interaction with the actual cluster. StableName() string // NetworkName the cluster is on NetworkName() string // MinKubeVersion returns true if the cluster is at least the version specified, // false otherwise MinKubeVersion(minor uint) bool
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 3K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters.go
match.Not(match.Network(from.Config().Cluster.NetworkName()))) return match.Not(excluded) } // reachableNakedDestinations filters out naked instances that aren't on the same network. // While External services are considered "naked", we won't see 500s due to different loadbalancing. func reachableNakedDestinations(from echo.Instance) match.Matcher { srcNw := from.Config().Cluster.NetworkName() excluded := match.And(
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 29 23:48:45 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/kube.go
func (e *Environment) ClustersByNetwork() map[string][]cluster.Cluster { out := make(map[string][]cluster.Cluster) for _, c := range e.Clusters() { out[c.NetworkName()] = append(out[c.NetworkName()], c) } return out } // ID implements resource.Instance func (e *Environment) ID() resource.ID { return e.id } func (e *Environment) Settings() *Settings {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.1K bytes - Viewed (0) -
tests/integration/telemetry/tracing/zipkin/client_tracing_test.go
func TestClientTracing(t *testing.T) { framework.NewTest(t). Run(func(t framework.TestContext) { appNsInst := tracing.GetAppNamespace() for _, cluster := range t.Clusters().ByNetwork()[t.Clusters().Default().NetworkName()] { cluster := cluster t.NewSubTest(cluster.StableName()).Run(func(ctx framework.TestContext) { retry.UntilSuccessOrFail(ctx, func() error { // Send test traffic with a trace header.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 2.4K bytes - Viewed (0) -
tests/integration/pilot/workloadentry_test.go
} gatewayAddresses := map[string]gwAddr{} for _, cluster := range t.Clusters() { if _, ok := gatewayAddresses[cluster.NetworkName()]; ok { continue } ips, ports := i.EastWestGatewayFor(cluster).AddressesForPort(15443) if ips != nil { gatewayAddresses[cluster.NetworkName()] = gwAddr{ips[0], ports[0]} } } if len(t.Clusters().Networks()) != len(gatewayAddresses) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 7.1K bytes - Viewed (0) -
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)