Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for CSIDrivers (0.14 sec)

  1. pkg/registry/storage/csidriver/strategy_test.go

    }
    
    func TestCSIDriverStrategy(t *testing.T) {
    	ctx := genericapirequest.WithRequestInfo(genericapirequest.NewContext(), &genericapirequest.RequestInfo{
    		APIGroup:   "storage.k8s.io",
    		APIVersion: "v1",
    		Resource:   "csidrivers",
    	})
    	if Strategy.NamespaceScoped() {
    		t.Errorf("CSIDriver must not be namespace scoped")
    	}
    	if Strategy.AllowCreateOnUpdate() {
    		t.Errorf("CSIDriver should not allow create on update")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  2. pkg/volume/csi/csi_plugin_test.go

    	client.Tracker().Add(&api.Node{
    		ObjectMeta: meta.ObjectMeta{
    			Name: "fakeNode",
    		},
    		Spec: api.NodeSpec{},
    	})
    
    	// Start informer for CSIDrivers.
    	factory := informers.NewSharedInformerFactory(client, CsiResyncPeriod)
    	csiDriverInformer := factory.Storage().V1().CSIDrivers()
    	csiDriverLister := csiDriverInformer.Lister()
    	volumeAttachmentInformer := factory.Storage().V1().VolumeAttachments()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  3. pkg/volume/csi/csi_plugin.go

    type RegistrationHandler struct {
    }
    
    // TODO (verult) consider using a struct instead of global variables
    // csiDrivers map keep track of all registered CSI drivers on the node and their
    // corresponding sockets
    var csiDrivers = &DriversStore{}
    
    var nim nodeinfomanager.Interface
    
    // PluginHandler is the plugin registration handler interface passed to the
    // pluginwatcher module in kubelet
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 29.2K bytes
    - Viewed (0)
  4. pkg/volume/csi/nodeinfomanager/nodeinfomanager.go

    	}
    
    	return nil
    }
    
    // UninstallCSIDriver removes the node ID annotation from the Node object and CSIDrivers field from the
    // CSINode object. If the CSINodeInfo object contains no CSIDrivers, it will be deleted.
    // If multiple calls to UninstallCSIDriver() are made in parallel, some calls might receive Node or
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 11 09:02:45 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  5. pkg/kubelet/volume_host.go

    	// 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)
  6. pkg/controller/volume/attachdetach/attach_detach_controller_test.go

    		informerFactory.Core().V1().Nodes(),
    		informerFactory.Core().V1().PersistentVolumeClaims(),
    		informerFactory.Core().V1().PersistentVolumes(),
    		informerFactory.Storage().V1().CSINodes(),
    		informerFactory.Storage().V1().CSIDrivers(),
    		informerFactory.Storage().V1().VolumeAttachments(),
    		plugins,
    		nil, /* prober */
    		false,
    		1*time.Second,
    		false,
    		DefaultTimerConfig,
    	)
    
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 11:00:37 UTC 2024
    - 24.2K bytes
    - Viewed (0)
  7. cmd/kube-controller-manager/app/core.go

    	logger := klog.FromContext(ctx)
    	csiNodeInformer := controllerContext.InformerFactory.Storage().V1().CSINodes()
    	csiDriverInformer := controllerContext.InformerFactory.Storage().V1().CSIDrivers()
    
    	plugins, err := ProbeAttachableVolumePlugins(logger)
    	if err != nil {
    		return nil, true, fmt.Errorf("failed to probe volume plugins when starting attach/detach controller: %v", err)
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 10 08:42:31 UTC 2024
    - 39K bytes
    - Viewed (0)
Back to top