- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for IsConfig (0.29 sec)
-
pkg/test/framework/components/cluster/topology.go
if _, f := knownClusterNames[c.Name()]; f { return c.Name() } if c.IsPrimary() { if c.IsConfig() { prefix = "primary" } else { prefix = "externalistiod" } } else if c.IsRemote() { if c.IsConfig() { prefix = "config" } else { prefix = "remote" } } return fmt.Sprintf("%s-%d", prefix, c.Index) }
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
// IsPrimary returns true if this is a primary cluster, containing an instance // of the Istio control plane. IsPrimary() bool // IsConfig returns true if this is a config cluster, used as the source of // Istio config for one or more control planes. IsConfig() bool // IsRemote returns true if this is a remote cluster, which uses a control plane // residing in another cluster. IsRemote() 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/istio/kube.go
// This MUST match the clusterName in the remote secret for this cluster. clusterName := c.Name() if !c.IsConfig() { clusterName = c.ConfigName() } args.AppendSet("values.global.multiCluster.clusterName", clusterName) } if err := i.installer.Install(c, args); err != nil { return err } if c.IsConfig() { // this is a traditional primary cluster, install the eastwest gateway
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 31.1K bytes - Viewed (0) -
pkg/test/framework/components/cluster/clusters.go
}, exclude(excluded...)) } // Configs returns the subset that are config clusters. func (c Clusters) Configs(excluded ...Cluster) Clusters { return c.filterClusters(func(cc Cluster) bool { return cc.IsConfig() }, exclude(excluded...)) } // Remotes returns the subset that are remote clusters. func (c Clusters) Remotes(excluded ...Cluster) Clusters { return c.filterClusters(func(cc Cluster) bool {
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/suite.go
s.requireFns = append(s.requireFns, fn) return s } func (s *suiteImpl) SkipExternalControlPlaneTopology() Suite { fn := func(ctx resource.Context) error { for _, c := range ctx.Clusters() { if c.IsConfig() && !c.IsPrimary() { s.Skip(fmt.Sprintf("Cluster %s is a config cluster, we can't run external control plane topology", c.Name())) } } return nil } s.requireFns = append(s.requireFns, fn)
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/kube/deployment.go
type deployment struct { ctx resource.Context cfg echo.Config shouldCreateWLE bool } func newDeployment(ctx resource.Context, cfg echo.Config) (*deployment, error) { if !cfg.Cluster.IsConfig() && cfg.DeployAsVM { return nil, fmt.Errorf("cannot deploy %s/%s as VM on non-config %s", cfg.Namespace.Name(), cfg.Service, cfg.Cluster.Name()) } if cfg.DeployAsVM {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 24.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/telemetry/tsconfig.json
{ /* Visit https://aka.ms/tsconfig.json to read more about this file */ "compilerOptions": { "target": "ES2022", "module": "ES2022", "moduleResolution": "node", "strict": true, "allowUnusedLabels": false, "allowUnreachableCode": false, "exactOptionalPropertyTypes": true, "noFallthroughCasesInSwitch": true, "noImplicitOverride": true, "noImplicitReturns": true,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 04 17:57:25 UTC 2024 - 683 bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
sconfig.Net.TLS.Config.RootCAs = h.kconfig.TLS.RootCAs // These settings are needed to ensure that kafka client doesn't hang on brokers // refer https://github.com/IBM/sarama/issues/765#issuecomment-254333355 sconfig.Producer.Retry.Max = 2 sconfig.Producer.Retry.Backoff = (10 * time.Second) sconfig.Producer.Return.Successes = true sconfig.Producer.Return.Errors = true sconfig.Producer.RequiredAcks = 1
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Sun Jun 02 03:03:39 UTC 2024 - 10.2K bytes - Viewed (0) -
tests/integration/helm/upgrade/util.go
nsConfig.Get(helmtest.CniReleaseName), overrideValuesFile, helmtest.Timeout) if err != nil { ctx.Fatalf("failed to upgrade istio %s chart", helmtest.CniReleaseName) } } if isAmbient { // Upgrade ztunnel chart err = h.UpgradeChart(helmtest.ZtunnelReleaseName, filepath.Join(helmtest.ManifestsChartPath, helmtest.ZtunnelChartsDir),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 14.4K bytes - Viewed (0) -
tests/integration/helm/util.go
result := make(nsConfig, len(config)) for _, c := range config { result[c.Name] = c.Namespace } return result } type nsConfig map[string]string func (n nsConfig) Get(name string) string { if ns, ok := n[name]; ok { return ns } return IstioNamespace } func (n nsConfig) Set(name, ns string) { n[name] = ns }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 19:04:51 UTC 2024 - 18.7K bytes - Viewed (0)