- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 340 for clusterIPs (0.19 sec)
-
pilot/pkg/networking/core/cluster.go
clusters = outboundPatcher.conditionallyAppend(clusters, nil, cb.buildBlackHoleCluster(), cb.buildDefaultPassthroughCluster()) clusters = append(clusters, outboundPatcher.insertedClusters()...) // Setup inbound clusters inboundPatcher := clusterPatcher{efw: envoyFilterPatches, pctx: networking.EnvoyFilter_SIDECAR_INBOUND}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
var expectedClusters cluster.Clusters if ht == hostTypeClusterLocal { // Ensure that all requests to cluster.local stay in the same cluster expectedClusters = cluster.Clusters{from.Config().Cluster} } else { // Ensure that requests to clusterset.local reach all destination clusters. expectedClusters = to.Clusters() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/deployment/builder.go
} b.templates = templates return b.WithClusters(clusters...) } type builder struct { ctx resource.Context // clusters contains the current set of clusters that subsequent With calls will be applied to, // if the Config passed to With does not explicitly choose a cluster. clusters cluster.Clusters
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12K bytes - Viewed (0) -
pkg/test/framework/components/echo/check/checkers.go
if from == nil || to == nil { // We need src and target in order to determine which clusters should be reached. return nil } if result.Opts.Count < to.Clusters().Len() { // There weren't enough calls to hit all the target clusters. Don't bother // checking which clusters were reached. return nil } allClusters := t.Clusters() if isNaked(from) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 03 16:19:07 UTC 2023 - 17.5K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/proxyconfig.go
istioctl proxy-config clusters <pod-name[.namespace]> # Retrieve cluster summary for clusters with port 9080. istioctl proxy-config clusters <pod-name[.namespace]> --port 9080 # Retrieve full cluster dump for clusters that are inbound with a FQDN of details.default.svc.cluster.local.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 48K bytes - Viewed (0) -
pkg/test/framework/test.go
// max clusters doesn't check kube only, the test may be written in a way that doesn't loop over all of Clusters() if t.requiredMaxClusters > 0 && len(t.s.Environment().Clusters()) > t.requiredMaxClusters { t.goTest.Skipf("Skipping %q: number of clusters %d is above required max %d", t.goTest.Name(), len(t.s.Environment().Clusters()), t.requiredMaxClusters) return } if t.minKubernetesMinorVersion > 0 { for _, c := range ctx.Clusters() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/kubelet/network/dns/dns.go
func NewConfigurer(recorder record.EventRecorder, nodeRef *v1.ObjectReference, nodeIPs []net.IP, clusterDNS []net.IP, clusterDomain, resolverConfig string) *Configurer { return &Configurer{ recorder: recorder, getHostDNSConfig: getHostDNSConfig, nodeRef: nodeRef, nodeIPs: nodeIPs, clusterDNS: clusterDNS, ClusterDomain: clusterDomain, ResolverConfig: resolverConfig, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 04 11:37:10 UTC 2023 - 16.1K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
timeouts = monitoring.NewSum( "remote_cluster_sync_timeouts_total", "Number of times remote clusters took too long to sync, causing slow startup that excludes remote clusters.", ) clusterType = monitoring.CreateLabel("cluster_type") clustersCount = monitoring.NewGauge( "istiod_managed_clusters", "Number of clusters managed by istiod", ) localClusters = clustersCount.With(clusterType.Value("local"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/test/framework/suite.go
// RequireMinClusters ensures that the current environment contains at least the given number of clusters. // Otherwise it stops test execution. // // Deprecated: Tests should not make assumptions about number of clusters. RequireMinClusters(minClusters int) Suite // RequireMaxClusters ensures that the current environment contains at least the given number of clusters. // Otherwise it stops test execution. //
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/run.go
t.toEachDeployment(t.rootCtx, func(ctx framework.TestContext, dstInstances echo.Instances) { t.setupPair(ctx, nil, echo.Services{dstInstances}) if len(ctx.Clusters()) == 1 { testFn(ctx, ctx.Clusters()[0], dstInstances) } else { t.fromEachCluster(ctx, func(ctx framework.TestContext, c cluster.Cluster) { testFn(ctx, c, dstInstances) }) } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Sep 27 22:08:42 UTC 2023 - 13K bytes - Viewed (0)