- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for CSIDrivers (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)