scottk/kubernetes
1
0
Fork 0
mirror of https://github.com/optim-enterprises-bv/kubernetes.git synced 2025-11-03 19:58:17 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make type BlockVolume a MetricsProvider

Browse Source
This commit is contained in:
Niels de Vos
2021-01-20 09:18:25 +01:00
parent e22012950b
commit de3a4429d9
2 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
pkg/volume/csi/csi_plugin.go
View File

@@ -703,7 +703,7 @@ func (p *csiPlugin) NewBlockVolumeMapper(spec *volume.Spec, podRef *api.Pod, opt
return nil, errors.New(log("failed to get device path: %v", err)) return nil, errors.New(log("failed to get device path: %v", err))
} }
mapper.MetricsProvider = NewMetricsCsi(pvSource.VolumeHandle, blockPath, csiDriverName(pvSource.Driver)) mapper.MetricsProvider = NewMetricsCsi(pvSource.VolumeHandle, blockPath+"/"+string(podRef.UID), csiDriverName(pvSource.Driver))
// persist volume info data for teardown // persist volume info data for teardown
node := string(p.host.GetNodeName()) node := string(p.host.GetNodeName())

4
pkg/volume/volume.go
View File

@@ -48,6 +48,10 @@ type BlockVolume interface {
// and name of a symbolic link associated to a block device. // and name of a symbolic link associated to a block device.
// ex. pods/{podUid}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/, {volumeName} // ex. pods/{podUid}/{DefaultKubeletVolumeDevicesDirName}/{escapeQualifiedPluginName}/, {volumeName}
GetPodDeviceMapPath() (string, string) GetPodDeviceMapPath() (string, string)
// MetricsProvider embeds methods for exposing metrics (e.g.
// used, available space).
MetricsProvider
} }
// MetricsProvider exposes metrics (e.g. used,available space) related to a // MetricsProvider exposes metrics (e.g. used,available space) related to a