- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 121 for driverNames (0.16 sec)
-
pkg/kubelet/cm/dra/plugin/noderesources.go
c.mutex.Lock() defer c.mutex.Unlock() if active, ok := c.activePlugins[driverName]; ok { active.cancel(errors.New("plugin has unregistered")) delete(c.activePlugins, driverName) c.queue.Add(driverName) } } // monitorPlugin calls the plugin to retrieve resource information and caches // all responses that it gets for processing in the sync method. It keeps
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 20:12:53 UTC 2024 - 16.6K bytes - Viewed (0) -
pkg/apis/resource/validation/validation_resourceslice_test.go
"k8s.io/kubernetes/pkg/apis/resource" "k8s.io/utils/ptr" ) func testResourceSlice(name, nodeName, driverName string) *resource.ResourceSlice { return &resource.ResourceSlice{ ObjectMeta: metav1.ObjectMeta{ Name: name, }, NodeName: nodeName, DriverName: driverName, ResourceModel: resource.ResourceModel{ NamedResources: &resource.NamedResourcesResources{}, }, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 14 17:07:36 UTC 2024 - 8.9K bytes - Viewed (0) -
pkg/volume/flexvolume/plugin.go
metricsProvider = volume.NewMetricsStatFS(plugin.host.GetPodVolumeDir( podUID, utilstrings.EscapeQualifiedName(plugin.driverName), volName)) } else { metricsProvider = &volume.MetricsNil{} } return &flexVolumeUnmounter{ flexVolume: &flexVolume{ driverName: plugin.driverName, execPath: plugin.getExecutable(), mounter: mounter, plugin: plugin,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 9.7K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin_test.go
t.Error("unexpected volumeHandle constructed:", volHandle) } driverName := rec.Spec.PersistentVolume.Spec.CSI.Driver if driverName != tc.originSpec.PersistentVolume.Spec.CSI.Driver { t.Error("unexpected driverName constructed:", driverName) } if rec.Spec.PersistentVolume.Spec.VolumeMode == nil { t.Fatalf("Volume mode has not been set.") }
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_drivers_store.go
// This method is protected by a mutex. func (s *DriversStore) Get(driverName string) (Driver, bool) { s.RLock() defer s.RUnlock() driver, ok := s.store[driverName] return driver, ok } // Set lets you save a CSI Driver to the list and give it a specific name. // This method is protected by a mutex. func (s *DriversStore) Set(driverName string, driver Driver) { s.Lock() defer s.Unlock() if s.store == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 16 11:12:06 UTC 2022 - 1.8K bytes - Viewed (0) -
pkg/volume/csi/csi_plugin.go
pod: pod, podUID: pod.UID, driverName: csiDriverName(driverName), volumeLifecycleMode: volumeLifecycleMode, volumeID: volumeHandle, specVolumeID: spec.Name(), readOnly: readOnly, kubeVolHost: kvh, } mounter.csiClientGetter.driverName = csiDriverName(driverName) dir := mounter.GetPath()
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/apis/resource/validation/validation_resourceclassparameters_test.go
parameters.VendorParameters = []resource.VendorParameters{ { DriverName: goodName, }, { DriverName: badName, }, } return parameters }(), }, "parameters-duplicate-driver": { wantFailures: field.ErrorList{field.Duplicate(field.NewPath("vendorParameters").Index(1).Child("driverName"), goodName)}, parameters: func() *resource.ResourceClassParameters {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:21:16 UTC 2024 - 11.8K bytes - Viewed (0) -
pkg/apis/resource/validation/validation_resourceclaim_test.go
claim.Status.DriverName = "valid" return claim }, }, "invalid-add-allocation": { wantFailures: field.ErrorList{field.Required(field.NewPath("status", "driverName"), "must be specified when `allocation` is set")}, oldClaim: validClaim, update: func(claim *resource.ResourceClaim) *resource.ResourceClaim { // DriverName must also get set here!
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 09:18:10 UTC 2024 - 28.7K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
func (nim *nodeInfoManager) UninstallCSIDriver(driverName string) error { err := nim.uninstallDriverFromCSINode(driverName) if err != nil { return fmt.Errorf("error uninstalling CSI driver from CSINode object %v", err) } err = nim.updateNode( removeMaxAttachLimit(driverName), removeNodeIDFromNode(driverName), ) if err != nil {
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/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go
existingPods []*v1.Pod filterName string driverName string maxVols int32 test string wantStatus *framework.Status wantPreFilterStatus *framework.Status }{ { newPod: oneVolPod, existingPods: []*v1.Pod{twoVolPod, oneVolPod}, filterName: ebsVolumeFilterType, driverName: csilibplugins.AWSEBSInTreePluginName, maxVols: 4,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 36.8K bytes - Viewed (0)