- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for driverNames (0.3 sec)
-
pkg/volume/util/volumeattributesclass_test.go
driverName: dirverName1, classes: []*storagev1alpha1.VolumeAttributesClass{vac1, vac2, vac6}, expect: nil, }, { name: "no default volume attributes class for the driverName1", driverName: dirverName1, classes: []*storagev1alpha1.VolumeAttributesClass{vac1, vac2, vac6, vac7}, expect: nil, }, { name: "one default volume attributes class for the driverName1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 03:18:56 UTC 2023 - 5.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/structuredparameters.go
} if c.classParameters != nil { for _, p := range c.classParameters.VendorParameters { if p.DriverName == driverName { handle.StructuredData.VendorClassParameters = p.Parameters break } } } for _, request := range c.claimParameters.DriverRequests { if request.DriverName == driverName { handle.StructuredData.VendorClaimParameters = request.VendorParameters break } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 09:03:22 UTC 2024 - 8.7K bytes - Viewed (0) -
pkg/volume/csi/csi_metrics.go
func NewMetricsCsi(volumeID string, targetPath string, driverName csiDriverName) volume.MetricsProvider { mc := &metricsCsi{volumeID: volumeID, targetPath: targetPath} mc.csiClientGetter.driverName = driverName return mc } func (mc *metricsCsi) GetMetrics() (*volume.Metrics, error) { startTime := time.Now() defer servermetrics.CollectVolumeStatCalDuration(string(mc.csiClientGetter.driverName), startTime) currentTime := metav1.Now()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Sep 11 06:07:40 UTC 2023 - 3.9K 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_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/util/attach_limit_test.go
if csiLimitKeyLonger != expectedCSIKey { t.Errorf("Expected limit to be %s got %s", expectedCSIKey, csiLimitKeyLonger) } } func getDriverHash(driverName string) string { charsFromDriverName := driverName[:23] hash := sha1.New() hash.Write([]byte(driverName)) hashed := hex.EncodeToString(hash.Sum(nil)) hashed = hashed[:16] return CSIAttachLimitPrefix + charsFromDriverName + hashed
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 05 16:29:00 UTC 2018 - 1.7K bytes - Viewed (0) -
pkg/volume/util/attach_limit.go
) // GetCSIAttachLimitKey returns limit key used for CSI volumes func GetCSIAttachLimitKey(driverName string) string { csiPrefixLength := len(CSIAttachLimitPrefix) totalkeyLength := csiPrefixLength + len(driverName) if totalkeyLength >= ResourceNameLengthLimit { charsFromDriverName := driverName[:23] hash := sha1.New() hash.Write([]byte(driverName)) hashed := hex.EncodeToString(hash.Sum(nil)) hashed = hashed[:16]
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Nov 10 17:25:30 UTC 2022 - 2.7K bytes - Viewed (0) -
pkg/volume/flexvolume/volume.go
import ( "k8s.io/mount-utils" utilstrings "k8s.io/utils/strings" "k8s.io/apimachinery/pkg/types" "k8s.io/kubernetes/pkg/volume" ) type flexVolume struct { // driverName is the name of the plugin driverName. driverName string // Driver executable used to setup the volume. execPath string // mounter provides the interface that is used to mount the actual // block device. mounter mount.Interface
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Sep 17 04:51:24 UTC 2020 - 1.6K bytes - Viewed (0) -
pkg/volume/csi/csi_util_test.go
os.Exit(m.Run()) } func makeTestPVWithMountOptions(name string, sizeGig int, driverName, volID string, mountOptions []string) *api.PersistentVolume { pv := makeTestPV(name, sizeGig, driverName, volID) pv.Spec.MountOptions = mountOptions return pv } func makeTestPV(name string, sizeGig int, driverName, volID string) *api.PersistentVolume { return &api.PersistentVolume{ ObjectMeta: meta.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 20 14:49:03 UTC 2023 - 5.5K bytes - Viewed (0)