- Sort Score
- Result 10 results
- Languages All
Results 11 - 15 of 15 for testConfig (0.2 sec)
-
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)