Versions in this module Expand all Collapse all v0 v0.1.0 Jul 1, 2024 Changes in this version + const APIVersion + const CRNameSpace + const DiskIOAnnotation + const EmptyDir + const FakeDeviceID + const Mi + const NodeDiskDeviceCRSuffix + const NodeDiskIOInfoCRSuffix + const NodeIOStatusCR + const Others + const PeriodicUpdateInterval + var BlockSize = []string + var MinDefaultIOBW resource.Quantity = resource.MustParse("5Mi") + var MinDefaultTotalIOBW resource.Quantity = resource.MustParse("10Mi") + var UpdateBackoff = wait.Backoff + func EstimateRequest(ioReq string) (*v1alpha1.IOBandwidth, error) + func GetCRName(n string, suff string) string + func GetSliceIdx(target string, s []string) int + type Config struct + Kubeconfig string + type DeviceType string + type DiskInfo struct + Capacity string + MajorMinor string + Model string + MountPoint string + Name string + ReadRatio map[string]float64 + TotalBPS resource.Quantity + TotalRBPS resource.Quantity + TotalWBPS resource.Quantity + Type DeviceType + Vendor string + WriteRatio map[string]float64 + func GetFakeDevice() *DiskInfo + type DiskInfos struct + EmptyDir string + Info map[string]*DiskInfo + func GetDiskProfile() *DiskInfos + type IODriver struct + func NewIODriver(cfg Config) (*IODriver, error) + func (c *IODriver) AddNodeDiskIOStatsCR(obj interface{}) + func (c *IODriver) ProcessProfile(ctx context.Context, di *DiskInfos) error + func (c *IODriver) Run(ctx context.Context) + func (c *IODriver) UpdateNodeDiskIOStatsCR(oldObj, newObj interface{}) + func (c *IODriver) WatchNodeDiskIOStats(ctx context.Context) error + func (e *IODriver) CreateNodeDiskDeviceCR(ctx context.Context, c *v1alpha1.NodeDiskDevice) error + func (e *IODriver) GetNodeDiskIOStats(ctx context.Context) (*v1alpha1.NodeDiskIOStats, error) + func (e *IODriver) UpdateNodeDiskIOInfoStatus(ctx context.Context, toUpdate map[string]v1alpha1.IOBandwidth) error + type IORequest struct + BlockSize string + Rbps string + Wbps string + type PodCrInfo struct
Go to main page