- Sort Score
- Result 10 results
- Languages All
Results 11 - 19 of 19 for testConfig (0.24 sec)
-
pkg/kube/util.go
} clientConfig := clientcmd.NewDefaultClientConfig(*rawConfig, &clientcmd.ConfigOverrides{}) restConfig, err := clientConfig.ClientConfig() if err != nil { return nil, err } for _, co := range configOverrides { co(restConfig) } return SetRestDefaults(restConfig), nil } // InClusterConfig returns the rest.Config for in cluster usage.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 18.6K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/genericclioptions/config_flags.go
// and eliminate the direct coupling to a struct type. Users may wish to duplicate this type in their own packages // as per the golang type overlapping. type RESTClientGetter interface { // ToRESTConfig returns restconfig ToRESTConfig() (*rest.Config, error) // ToDiscoveryClient returns discovery client ToDiscoveryClient() (discovery.CachedDiscoveryInterface, error) // ToRESTMapper returns a restmapper
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 11 15:04:11 UTC 2023 - 16.9K bytes - Viewed (0) -
tools/bug-report/pkg/bugreport/bugreport.go
restConfig, clientset, err := kubeclient.New(config.KubeConfigPath, config.Context) if err != nil { return fmt.Errorf("could not initialize k8s client: %s ", err) } client, err := kube.NewCLIClient(kube.NewClientConfigForRestConfig(restConfig)) if err != nil { return err } common.LogAndPrintf("\nCluster endpoint: %s\n", client.RESTConfig().Host) runner.SetClient(client)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 20:57:29 UTC 2024 - 20.7K bytes - Viewed (0) -
operator/pkg/helmreconciler/reconciler.go
if err != nil { return "", err } crNamespace, err := h.getCRNamespace() if err != nil { return "", err } var host string if h.kubeClient != nil && h.kubeClient.RESTConfig() != nil { host = h.kubeClient.RESTConfig().Host } return strings.Join([]string{crName, crNamespace, componentName, host}, "-"), nil } // getCRNamespace returns the namespace of the CR associated with h.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 22 08:32:23 UTC 2024 - 22K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/proxy/streamtunnel_test.go
"k8s.io/apimachinery/pkg/util/httpstream/spdy" constants "k8s.io/apimachinery/pkg/util/portforward" "k8s.io/apimachinery/pkg/util/proxy" "k8s.io/apimachinery/pkg/util/wait" "k8s.io/apiserver/pkg/registry/rest" restconfig "k8s.io/client-go/rest" "k8s.io/client-go/tools/portforward" ) func TestTunnelingHandler_UpgradeStreamingAndTunneling(t *testing.T) { // Create fake upstream SPDY server, with channel receiving SPDY streams.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 02:21:50 UTC 2024 - 22.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/configcontroller.go
// Controller should be created for calling the run function every time, so it can // avoid concurrently calling of informer Run() for controller in controller.Start controller := distribution.NewController(s.kubeClient.RESTConfig(), args.Namespace, s.RWConfigStore, s.statusManager) s.statusReporter.SetController(controller) controller.Start(leaderStop) }).Run(stop) return nil }) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 14.1K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune.go
if c == string(name.PilotComponentName) { pilotEnabled = true break } } // If istiod is enabled, check if it has any proxies connected. if pilotEnabled { cfg := h.kubeClient.RESTConfig() kubeClient, err := kube.NewCLIClient(kube.NewClientConfigForRestConfig(cfg), kube.WithRevision(iopSpec.Revision)) if err != nil { return errStatus, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 15.9K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
resName := webhookName if resName == "" { resName = fmt.Sprintf("%s-%s", "istio-revision-tag", tagName) } if err := analyzeWebhook(resName, istioNS, tagWhYAML, revision, kubeClient.RESTConfig()); err != nil { // if we have a conflict, we will fail. If --skip-confirmation is set, we will continue with a // warning; when actually applying we will also confirm to ensure the user does not see the
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 16.3K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret.go
return fmt.Errorf("failed creating namespace %s: %v", ns, err) } } return nil } func getServerFromKubeconfig(client kube.CLIClient) (string, Warning, error) { restCfg := client.RESTConfig() if restCfg == nil { return "", nil, fmt.Errorf("failed getting REST config from client") } server := restCfg.Host if strings.Contains(server, "127.0.0.1") || strings.Contains(server, "localhost") {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Oct 11 01:43:17 UTC 2023 - 24K bytes - Viewed (0)