- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 63 for testConfig (0.31 sec)
-
operator/cmd/mesh/shared.go
return true case "N", "NO": return false } } } func KubernetesClients(kubeClient kube.CLIClient, l clog.Logger) (kube.CLIClient, client.Client, error) { client, err := client.New(kubeClient.RESTConfig(), client.Options{Scheme: kube.IstioScheme}) if err != nil { return nil, nil, err } if err := k8sversion.IsK8VersionSupported(kubeClient, l); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 29 02:29:02 UTC 2024 - 5.1K bytes - Viewed (0) -
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/apiserver/pkg/server/storage/storage_factory_test.go
if !reflect.DeepEqual(config.Transport.ServerList, defaultEtcdLocation) { t.Errorf("%d: expected %v, got %v", i, defaultEtcdLocation, config.Transport.ServerList) continue } } } func TestConfigs(t *testing.T) { exampleinstall.Install(scheme) defaultEtcdLocations := []string{"http://127.0.0.1", "http://127.0.0.2"} testCases := []struct { resource *schema.GroupResource servers []string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 20 13:35:58 UTC 2023 - 7.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) -
pkg/kubelet/certificate/transport.go
"k8s.io/apimachinery/pkg/util/wait" restclient "k8s.io/client-go/rest" "k8s.io/client-go/util/certificate" "k8s.io/client-go/util/connrotation" ) // UpdateTransport instruments a restconfig with a transport that dynamically uses // certificates provided by the manager for TLS client auth. // // The config must not already provide an explicit transport. //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 08 13:57:45 UTC 2022 - 6.5K 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)