Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type VolumeCgroupsManager ¶
type VolumeCgroupsManager interface { // ConfigureQoSForDevice configures the QoS for a volume. ConfigureQoSForDevice(devPath string, iops, throughput int64) error }
VolumeCgroupsManager is the interface to configure QoS for a volume.
func NewVolumeCgroupsManager ¶
func NewVolumeCgroupsManager() (VolumeCgroupsManager, error)
NewVolumeCgroupsManager returns a VolumeCgroupsManager according to the cgroups mode.
type VolumeQoSManager ¶
type VolumeQoSManager struct {
// contains filtered or unexported fields
}
func NewVolumeQoSManager ¶
func NewVolumeQoSManager(nodeName string, client client.Client) (*VolumeQoSManager, error)
func (*VolumeQoSManager) ConfigureQoSForLocalVolumeReplica ¶
func (m *VolumeQoSManager) ConfigureQoSForLocalVolumeReplica(replica *apisv1alpha1.LocalVolumeReplica) error
ConfigureQoSForLocalVolumeReplica configures the QoS for a volume.
func (*VolumeQoSManager) IsFilesystemInitialized ¶
func (m *VolumeQoSManager) IsFilesystemInitialized(replica *apisv1alpha1.LocalVolumeReplica) bool
IsFilesystemInitialized checks if the filesystem is initialized. It must be called before configuring QoS for a volume. If the filesystem is not initialized, we should skip volume QoS configuration in order to void the mkfs process hangs, See #958 for details.
func (*VolumeQoSManager) RefreshQoSForLocalVolumeName ¶
func (m *VolumeQoSManager) RefreshQoSForLocalVolumeName(volumeName string) error
RefreshQoSForLocalVolume re-configures the QoS for a volume.
Click to show internal directories.
Click to hide internal directories.