- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 186 for kubeclient (0.2 sec)
-
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
RunE: func(c *cobra.Command, args []string) error { kubeClient, err := ctx.CLIClient() if err != nil { return err } var podNames []string var podNamespace string if len(args) == 1 { podName, ns, err := getComponentPodName(ctx, args[0]) if err != nil { return err } ztunnelPod := ambientutil.IsZtunnelPod(kubeClient, podName, ns) if !ztunnelPod {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 20:18:34 UTC 2024 - 22K bytes - Viewed (0) -
pkg/kubelet/volume_host.go
const resyncPeriod = 0 // Don't initialize if kubeClient is nil if kubelet.kubeClient != nil { informerFactory = informers.NewSharedInformerFactory(kubelet.kubeClient, resyncPeriod) csiDriverInformer := informerFactory.Storage().V1().CSIDrivers() csiDriverLister = csiDriverInformer.Lister() csiDriversSynced = csiDriverInformer.Informer().HasSynced } else { klog.InfoS("KubeClient is nil. Skip initialization of CSIDriverLister") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 11:00:37 UTC 2024 - 10K bytes - Viewed (0) -
operator/cmd/mesh/uninstall.go
if err != nil { return err } } else { kubeClientWithRev = kubeClient } if uiArgs.revision != "" { revisions, err := tag.ListRevisionDescriptions(kubeClient) if err != nil { return fmt.Errorf("could not list revisions: %s", err) } if _, exists := revisions[uiArgs.revision]; !exists { return errors.New("could not find target revision") } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 01:18:49 UTC 2024 - 10.4K bytes - Viewed (0) -
operator/cmd/mesh/operator-remove.go
} var installed bool if orArgs.revision == "default" { installed, err = isControllerInstalled(kubeClient.Kube(), orArgs.operatorNamespace, "") } else { installed, err = isControllerInstalled(kubeClient.Kube(), orArgs.operatorNamespace, orArgs.revision) } if installed && err != nil { l.LogAndFatal(err) } if !installed && !orArgs.purge {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 01:18:49 UTC 2024 - 5.4K bytes - Viewed (0) -
pkg/controller/volume/ephemeral/controller.go
} // NewController creates an ephemeral volume controller. func NewController( ctx context.Context, kubeClient clientset.Interface, podInformer coreinformers.PodInformer, pvcInformer coreinformers.PersistentVolumeClaimInformer) (Controller, error) { ec := &ephemeralController{ kubeClient: kubeClient, podLister: podInformer.Lister(), podIndexer: podInformer.Informer().GetIndexer(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 9.2K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
wg, waitForMockCalls := NewWaitForNCalls(t, 1) fs := &fakeServer{testWG: wg} fs.On("AddPodToMesh", ctx, pod, util.GetPodIPsIfPresent(pod), "", ).Return(nil) server := &meshDataplane{ kubeClient: client.Kube(), netServer: fs, } handlers := setupHandlers(ctx, client, server, "istio-system") client.RunAndWait(ctx.Done()) go handlers.Start() // label the namespace
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
istioctl/pkg/proxystatus/proxystatus.go
kubeClient, err := ctx.CLIClientWithRevision(opts.Revision) if err != nil { return err } multiXdsOpts.MessageWriter = c.OutOrStdout() if len(args) > 0 { podName, ns, err := ctx.InferPodInfoFromTypedResource(args[0], ctx.Namespace()) if err != nil { return err } if ambient.IsZtunnelPod(kubeClient, podName, ns) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 6.2K bytes - Viewed (0) -
pkg/kube/kclient/clienttest/direct.go
api := kubeclient.GetClient[T, TL](d.client, namespace) res, err := api.Get(context.Background(), name, metav1.GetOptions{}) if err != nil && !kerrors.IsNotFound(err) { d.t.Fatalf("get: %v", err) } return res } func (d *directClient[T, PT, TL]) List(namespace string, selector klabels.Selector) []T { api := kubeclient.GetClient[T, TL](d.client, namespace)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Aug 08 16:43:05 UTC 2023 - 3K bytes - Viewed (0) -
operator/pkg/helmreconciler/prune_test.go
for i, data := range gateways { iop := &v1alpha1.IstioOperator{} err := yaml.UnmarshalStrict(data, iop) assert.NoError(t, err) h := &HelmReconciler{ client: cl, kubeClient: kube.NewFakeClientWithVersion("24"), opts: &Options{ ProgressLog: progress.NewLog(), Log: clog.NewDefaultLogger(), }, iop: iop, countLock: &sync.Mutex{},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 12:13:37 UTC 2023 - 5.2K bytes - Viewed (0) -
istioctl/pkg/xds/client.go
if isMCP { // Special credentials handling when using ASM Managed Control Plane. mem, err := getHubMembership(ctx, kubeClient) if err != nil { return nil, fmt.Errorf("failed to query Hub membership: %w", err) } aud = []string{mem.WorkloadIdentityPool} } k8sCreds, err := kubeClient.CreatePerRPCCredentials(ctx, ns, serviceAccount, aud, defaultExpirationSeconds) if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 19 22:42:42 UTC 2023 - 3.7K bytes - Viewed (0)