- Sort Score
- Result 10 results
- Languages All
Results 11 - 18 of 18 for CSIDrivers (0.2 sec)
-
pkg/scheduler/framework/plugins/volumebinding/volume_binding.go
csiNodeInformer := fh.SharedInformerFactory().Storage().V1().CSINodes() capacityCheck := CapacityCheck{ CSIDriverInformer: fh.SharedInformerFactory().Storage().V1().CSIDrivers(), CSIStorageCapacityInformer: fh.SharedInformerFactory().Storage().V1().CSIStorageCapacities(), }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 16.4K bytes - Viewed (0) -
pkg/volume/csi/csi_client.go
} func newCsiDriverClient(driverName csiDriverName) (*csiDriverClient, error) { if driverName == "" { return nil, fmt.Errorf("driver name is empty") } existingDriver, driverExists := csiDrivers.Get(string(driverName)) if !driverExists { return nil, fmt.Errorf("driver name %s not found in the list of registered CSI drivers", driverName) } nodeV1ClientCreator := newV1NodeClient
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 20 10:15:36 UTC 2022 - 22.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/testdata/controller-roles.yaml
- storage.k8s.io resources: - volumeattachments verbs: - create - delete - get - list - watch - apiGroups: - storage.k8s.io resources: - csidrivers verbs: - get - list - watch - apiGroups: - storage.k8s.io resources: - csinodes verbs: - get - list - watch
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 26.6K bytes - Viewed (0) -
pkg/volume/csi/csi_test.go
}) client := fakeclient.NewSimpleClientset(objs...) factory := informers.NewSharedInformerFactory(client, time.Hour /* disable resync */) csiDriverInformer := factory.Storage().V1().CSIDrivers() volumeAttachmentInformer := factory.Storage().V1().VolumeAttachments() if driverInfo != nil { csiDriverInformer.Informer().GetStore().Add(driverInfo) } factory.Start(wait.NeverStop)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 03 15:55:13 UTC 2022 - 21.1K bytes - Viewed (0) -
pkg/scheduler/eventhandlers.go
); err != nil { return err } handlers = append(handlers, handlerRegistration) case framework.CSIDriver: if handlerRegistration, err = informerFactory.Storage().V1().CSIDrivers().Informer().AddEventHandler( buildEvtResHandler(at, framework.CSIDriver, "CSIDriver"), ); err != nil { return err } handlers = append(handlers, handlerRegistration)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:04 UTC 2024 - 24K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/rbac/bootstrappolicy/controller_policy.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 08 19:25:10 UTC 2024 - 28.9K 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) -
plugin/pkg/auth/authorizer/node/node_authorizer_test.go
}, // CSINode { name: "disallowed CSINode with subresource - feature enabled", attrs: authorizer.AttributesRecord{User: node0, ResourceRequest: true, Verb: "get", Resource: "csinodes", Subresource: "csiDrivers", APIGroup: "storage.k8s.io", Name: "node0"}, expect: authorizer.DecisionNoOpinion, }, { name: "disallowed get another node's CSINode",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 40.5K bytes - Viewed (0)