- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for clusterConfigs (0.27 sec)
-
pkg/test/framework/components/environment/kube/settings.go
if len(s.controlPlaneTopology) != len(clusterConfigs) { return nil, fmt.Errorf("istio.test.kube.controlPlaneTopology has %d entries but there are %d clusters", len(controlPlaneTopology), len(clusterConfigs)) } for src, dst := range s.controlPlaneTopology { clusterConfigs[src].PrimaryClusterName = clusterConfigs[dst].Name } } if s.configTopology != nil { if len(s.configTopology) != len(clusterConfigs) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 8.3K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/flags.go
// hold networkTopology from command line to parse later networkTopology string // hold configTopology from command line to parse later configTopology string // file defining all types of topology clusterConfigs configsVal ) // NewSettingsFromCommandLine returns Settings obtained from command-line flags. // config.Parse must be called before calling this function. func NewSettingsFromCommandLine() (*Settings, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 10.3K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/kube.go
`) } }() scopes.Framework.Infof("Test Framework Kubernetes environment Settings:\n%s", s) e := &Environment{ ctx: ctx, s: s, } e.id = ctx.TrackResource(e) configs, err := s.clusterConfigs() if err != nil { return nil, err } clusters, err := buildClusters(configs) if err != nil { return nil, err } e.clusters = clusters return e, nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller_test.go
} func makeSecret(namespace string, secret string, clusterConfigs ...clusterCredential) *v1.Secret { s := &v1.Secret{ ObjectMeta: metav1.ObjectMeta{ Name: secret, Namespace: namespace, Labels: map[string]string{ MultiClusterSecretLabel: "true", }, }, Data: map[string][]byte{}, } for _, config := range clusterConfigs { s.Data[config.clusterID] = config.kubeconfig } return s
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 15:07:03 UTC 2024 - 17.6K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/util/join.go
} // load the default cluster config _, clusterConfig := kubeconfigutil.GetClusterFromKubeConfig(config) if clusterConfig == nil { return "", errors.New("failed to get default cluster config") } // load CA certificates from the kubeconfig (either from PEM data or by file path) var caCerts []*x509.Certificate if clusterConfig.CertificateAuthorityData != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Dec 18 04:27:38 UTC 2022 - 3.9K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/fakeconfig_test.go
} type clusterConfig struct { configBase config kubeadmapiv1.ClusterConfiguration } func (cc *clusterConfig) DeepCopy() kubeadmapi.ComponentConfig { result := &clusterConfig{} cc.configBase.DeepCopyInto(&result.configBase) cc.config.DeepCopyInto(&result.config) return result } func (cc *clusterConfig) Marshal() ([]byte, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 04 15:36:00 UTC 2024 - 16.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/watcher_test.go
storagetesting.RunTestWatchInitializationSignal(ctx, t, store) } func TestProgressNotify(t *testing.T) { clusterConfig := testserver.NewTestConfig(t) clusterConfig.ExperimentalWatchProgressNotifyInterval = time.Second ctx, store, _ := testSetup(t, withClientConfig(clusterConfig)) storagetesting.RunOptionalTestProgressNotify(ctx, t, store) } // TestWatchDispatchBookmarkEvents makes sure that
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 12.3K bytes - Viewed (0) -
cluster/images/etcd/migrate/integration_test.go
} for _, m := range migrations { t.Run(m.title, func(t *testing.T) { start := mustParseEtcdVersionPair(m.startVersion) end := mustParseEtcdVersionPair(m.endVersion) testCfgs := clusterConfig(t, m.title, m.memberCount, m.protocol, m.clientListenUrls) servers := []*EtcdMigrateServer{} for _, cfg := range testCfgs { client, err := NewEtcdMigrateClient(cfg) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 28 07:33:23 UTC 2022 - 11.4K bytes - Viewed (0) -
tests/integration/pilot/forwardproxy/envoy_config_generator.go
ClusterType: &envoy_cluster.Cluster_CustomClusterType{ Name: "envoy.clusters.dynamic_forward_proxy", TypedConfig: protoconv.MessageToAny(&envoy_clusters_dynamic_forward_proxy.ClusterConfig{ ClusterImplementationSpecifier: &envoy_clusters_dynamic_forward_proxy.ClusterConfig_DnsCacheConfig{ DnsCacheConfig: dynamicForwardProxyCacheConfig, }, }), }, }, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 27 19:22:30 UTC 2023 - 8.8K bytes - Viewed (0)