Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for supportsMetrics (0.32 sec)

  1. pkg/volume/flexvolume/plugin.go

    	if err != nil {
    		return nil, err
    	}
    
    	readOnly, err := getReadOnly(spec)
    	if err != nil {
    		return nil, err
    	}
    
    	var metricsProvider volume.MetricsProvider
    	if plugin.capabilities.SupportsMetrics {
    		metricsProvider = volume.NewMetricsStatFS(plugin.host.GetPodVolumeDir(
    			pod.UID, utilstrings.EscapeQualifiedName(sourceDriver), spec.Name()))
    	} else {
    		metricsProvider = &volume.MetricsNil{}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 9.7K bytes
    - Viewed (0)
  2. pkg/volume/local/local.go

    	return globalPath, nil
    }
    
    // GetStagingPath returns
    func (m *localVolumeMapper) GetStagingPath() string {
    	return ""
    }
    
    // SupportsMetrics returns true for SupportsMetrics as it initializes the
    // MetricsProvider.
    func (m *localVolumeMapper) SupportsMetrics() bool {
    	return true
    }
    
    // localVolumeUnmapper implements the BlockVolumeUnmapper interface for local volumes.
    type localVolumeUnmapper struct {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 22.2K bytes
    - Viewed (0)
  3. pkg/volume/volume.go

    	// ex. pods/{podUid}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/, {volumeName}
    	GetPodDeviceMapPath() (string, string)
    
    	// SupportsMetrics should return true if the MetricsProvider is
    	// initialized
    	SupportsMetrics() bool
    
    	// MetricsProvider embeds methods for exposing metrics (e.g.
    	// used, available space).
    	MetricsProvider
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. pkg/volume/iscsi/iscsi.go

    type iscsiDiskUnmapper struct {
    	*iscsiDisk
    	exec       utilexec.Interface
    	deviceUtil ioutil.DeviceUtil
    	volume.MetricsNil
    }
    
    // SupportsMetrics returns true for SupportsMetrics as it initializes the
    // MetricsProvider.
    func (idm *iscsiDiskMapper) SupportsMetrics() bool {
    	return true
    }
    
    var _ volume.BlockVolumeUnmapper = &iscsiDiskUnmapper{}
    var _ volume.CustomBlockVolumeUnmapper = &iscsiDiskUnmapper{}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 06:17:25 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. pkg/kubelet/server/stats/volume_stat_calculator_test.go

    func (v *fakeBlockVolume) GetGlobalMapPath(*volume.Spec) (string, error) { return "", nil }
    
    func (v *fakeBlockVolume) GetPodDeviceMapPath() (string, string) { return "", "" }
    
    func (v *fakeBlockVolume) SupportsMetrics() bool { return true }
    
    func (v *fakeBlockVolume) GetMetrics() (*volume.Metrics, error) {
    	return expectedBlockMetrics(), nil
    }
    
    func expectedBlockMetrics() *volume.Metrics {
    	vMetrics := &volume.Metrics{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 9.6K bytes
    - Viewed (0)
  6. pkg/volume/csi/csi_block.go

    func (m *csiBlockMapper) GetStagingPath() string {
    	return filepath.Join(m.plugin.host.GetVolumeDevicePluginDir(CSIPluginName), "staging", m.specName)
    }
    
    // SupportsMetrics returns true for csiBlockMapper as it initializes the
    // MetricsProvider.
    func (m *csiBlockMapper) SupportsMetrics() bool {
    	return true
    }
    
    // getPublishDir returns path to a directory, where the volume is published to each pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Sep 11 06:07:40 UTC 2023
    - 20.1K bytes
    - Viewed (0)
Back to top