- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for testConfig (0.22 sec)
-
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
crNamespace := obj.GetLabels()[helmreconciler.OwningResourceNamespace] componentName := obj.GetLabels()[helmreconciler.IstioComponentLabelStr] var host string if restConfig != nil { host = restConfig.Host } crHash := strings.Join([]string{crName, crNamespace, componentName, host}, "-") oh := object.NewK8sObject(&unstructured.Unstructured{Object: unsObj}, nil, nil).Hash()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/kube/multicluster/secretcontroller.go
func DefaultBuildClientsFromConfig(kubeConfig []byte, clusterID cluster.ID, configOverrides ...func(*rest.Config)) (kube.Client, error) { restConfig, err := kube.NewUntrustedRestConfig(kubeConfig, configOverrides...) if err != nil { return nil, err } clients, err := kube.NewClient(kube.NewClientConfigForRestConfig(restConfig), clusterID) if err != nil { return nil, fmt.Errorf("failed to create kube clients: %v", err) }
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/kube/client.go
} c.http = &http.Client{ Timeout: time.Second * 15, } var clientWithTimeout kubernetes.Interface clientWithTimeout = c.kube restConfig := c.RESTConfig() if restConfig != nil { restConfig.Timeout = time.Second * 5 kubeClient, err := kubernetes.NewForConfig(restConfig) if err == nil { clientWithTimeout = kubeClient } } c.version = lazy.NewWithRetry(clientWithTimeout.Discovery().ServerVersion)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 39K 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/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)