- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 186 for kubeclient (0.32 sec)
-
istioctl/pkg/internaldebug/internal-debug.go
namespace, serviceAccount, kubeClient, multixds.DefaultOptions) if respErr != nil { return xdsResponses, respErr } _, _ = fmt.Fprint(writer, "error: according to below command list, please check all supported internal debug commands\n") return xdsResponses, nil } func HandlerForDebugErrors(kubeClient kube.CLIClient, centralOpts *clioptions.CentralControlPlaneOptions,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 04:16:55 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/controller/cronjob/injection.go
} // realCJControl is the default implementation of cjControlInterface. type realCJControl struct { KubeClient clientset.Interface } func (c *realCJControl) GetCronJob(ctx context.Context, namespace, name string) (*batchv1.CronJob, error) { return c.KubeClient.BatchV1().CronJobs(namespace).Get(ctx, name, metav1.GetOptions{}) } var _ cjControlInterface = &realCJControl{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 22 09:37:31 UTC 2023 - 4.7K bytes - Viewed (0) -
pkg/controller/nodeipam/node_ipam_controller.go
nodeInformer coreinformers.NodeInformer, cloud cloudprovider.Interface, kubeClient clientset.Interface, clusterCIDRs []*net.IPNet, serviceCIDR *net.IPNet, secondaryServiceCIDR *net.IPNet, nodeCIDRMaskSizes []int, allocatorType ipam.CIDRAllocatorType) (*Controller, error) { if kubeClient == nil { return nil, fmt.Errorf("kubeClient is nil when starting Controller") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 16:18:38 UTC 2024 - 5.4K bytes - Viewed (0) -
istioctl/pkg/waypoint/waypoint.go
return multiErr.ErrorOrNil() } func labelNamespaceWithWaypoint(kubeClient kube.CLIClient, ns string) error { nsObj, err := getNamespace(kubeClient, ns) if err != nil { return err } if nsObj.Labels == nil { nsObj.Labels = map[string]string{} } nsObj.Labels[constants.AmbientUseWaypointLabel] = waypointName
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 15:59:33 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/kubelet/volumemanager/volume_manager_test.go
} } } func delayClaimBecomesBound( kubeClient clientset.Interface, namespace, claimName string, ) { time.Sleep(500 * time.Millisecond) volumeClaim, _ := kubeClient.CoreV1().PersistentVolumeClaims(namespace).Get(context.TODO(), claimName, metav1.GetOptions{}) volumeClaim.Status = v1.PersistentVolumeClaimStatus{ Phase: v1.ClaimBound, }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.1K bytes - Viewed (0) -
operator/cmd/mesh/operator-init.go
for _, ns := range namespaces { if err := operatorutil.CreateNamespace(kubeClient.Kube(), ns, "", opts.DryRun); err != nil { l.LogAndFatal(err) } } if err := applyManifest(kubeClient, client, mstr, name.IstioOperatorComponentName, opts, iop, l); err != nil { l.LogAndFatal(err) } if customResource != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 01:18:49 UTC 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/tag/tag.go
} return nil }, RunE: func(cmd *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClient() if err != nil { return fmt.Errorf("failed to create Kubernetes client: %v", err) } return setTag(context.Background(), kubeClient, args[0], revision, ctx.IstioNamespace(), false, cmd.OutOrStdout(), cmd.OutOrStderr()) }, }
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/proxyconfig/proxyconfig.go
"off": OffLevel, } var ( loggerLevelString = "" reset = false ) func extractConfigDump(kubeClient kube.CLIClient, podName, podNamespace string, eds bool) ([]byte, error) { path := "config_dump" if eds { path += "?include_eds=true" } debug, err := kubeClient.EnvoyDoWithPort(context.TODO(), podName, podNamespace, "GET", path, proxyAdminPort) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 48K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconciler_test.go
kubeClient := createTestClient() fakeRecorder := &record.FakeRecorder{} fakeHandler := volumetesting.NewBlockVolumePathHandler() oex := operationexecutor.NewOperationExecutor(operationexecutor.NewOperationGenerator( kubeClient, volumePluginMgr, fakeRecorder, fakeHandler, )) reconciler := NewReconciler( kubeClient, false, /* controllerAttachDetachEnabled */
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 09 07:34:33 UTC 2024 - 75.4K bytes - Viewed (0) -
security/pkg/server/ca/authenticate/kubeauth/kube_jwt.go
} func (a *KubeJWTAuthenticator) authenticate(targetJWT string, clusterID cluster.ID) (*security.Caller, error) { kubeClient := a.getKubeClient(clusterID) if kubeClient == nil { return nil, fmt.Errorf("could not get cluster %s's kube client", clusterID) } id, err := tokenreview.ValidateK8sJwt(kubeClient, targetJWT, security.TokenAudiences) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0)