system

package

Go to main page

Versions in this module

v1

v1.5.0

Jun 3, 2024

Changes in this version

+ const BlkioIOModelName

+ const RuntimeTypeCrio

+ var BlkioIOModel = DefaultFactory.New(BlkioIOModelName, CgroupBlkioDir).WithValidator(BlkioIOModelValidator).WithSupported(SupportedIfFileExistsInRootCgroup(BlkioIOModelName, CgroupBlkioDir))

+ var BlkioIOModelValidator = &BlkIORangeValidator

type Config

+ CrioEndPoint string

+ VarLibKubeletRootDir string

+ type PSIByResource struct

+ CPU PSIStats

+ IO PSIStats

+ Mem PSIStats

+ func GetPSIByResource(paths PSIPath) (*PSIByResource, error)

+ type PSIPath struct

+ CPU string

+ IO string

+ Mem string

type PSIStats

+ func ParsePSIStats(r io.Reader) (PSIStats, error)

v1.4.1

Feb 26, 2024

Changes in this version

+ var CacheIdsCacheFunc func() ([]int, error)

+ func GetCacheIds() ([]int, error)

+ func GetSchedGroupIdentity() (bool, error)

+ func InitSupportConfigs()

+ func IsCoreSchedSupported() (bool, string)

+ func IsCoreSchedSysctlSupported() bool

+ func IsGroupIdentitySysctlSupported() bool

type ResctrlSchemataRaw

+ func (r *ResctrlSchemataRaw) CacheIds() []int

v1.4.0

Jan 9, 2024

Changes in this version

+ const CPUIdleName

+ const CgroupUnlimitedSymbolStr

+ const DefaultCoreSchedCookieID

+ const HugepageDir

+ const KernelSchedCore

+ const KidledRelativePath

+ const KidledScanPeriodInSecondsFileName

+ const KidledUseHierarchyFileFileName

+ const MemoryIdlePageStatsName

+ const ProcCPUInfoName

+ const RuntimeTypePouch

+ const SchedFeatureCoreSched

+ const SchedFeatureNoCoreSched

+ const SchedFeaturesFileName

+ const SchedFeaturesRelativePath

+ const SysCPUSMTActiveSubPath

+ const SysIntelPStateNoTurboSubPath

+ const SysPCIDeviceDir

+ const VirtualCoreSchedCookieName

+ var CPUBVTWarpNsV2 = DefaultFactory.NewV2(CPUBVTWarpNsName, CPUBVTWarpNsName).WithValidator(CPUBvtWarpNsValidator).WithCheckSupported(SupportedIfFileExists)

+ var CPUIdle = DefaultFactory.New(CPUIdleName, CgroupCPUDir).WithValidator(CPUIdleValidator).WithCheckSupported(SupportedIfFileExistsInKubepods).WithCheckOnce(true)

+ var CPUIdleV2 = DefaultFactory.NewV2(CPUIdleName, CPUIdleName).WithValidator(CPUIdleValidator).WithCheckSupported(SupportedIfFileExistsInKubepods).WithCheckOnce(true)

+ var CPUIdleValidator = &RangeValidator

+ var KidledScanPeriodInSeconds = NewCommonSystemResource(KidledRelativePath, KidledScanPeriodInSecondsFileName, GetSysRootDir).WithValidator(KidledScanPeriodInSecondsValidator).WithCheckSupported(SupportedIfFileExists)

+ var KidledScanPeriodInSecondsValidator = &RangeValidator

+ var KidledUseHierarchy = NewCommonSystemResource(KidledRelativePath, KidledUseHierarchyFileFileName, GetSysRootDir).WithValidator(KidledUseHierarchyValidator).WithCheckSupported(SupportedIfFileExists)

+ var KidledUseHierarchyValidator = &RangeValidator

+ var MemoryIdlePageStats = DefaultFactory.New(MemoryIdlePageStatsName, CgroupMemDir).WithCheckSupported(SupportedIfFileExistsInKubepods).WithCheckOnce(true)

+ var SchedFeatures = NewCommonSystemResource(SchedFeaturesRelativePath, SchedFeaturesFileName, GetSysRootDir).WithCheckSupported(SupportedIfFileExists)

+ var VirtualCoreSchedCookie = NewCommonSystemResource("", VirtualCoreSchedCookieName, GetProcRootDir)

+ func CheckResctrlSchemataValid() error

+ func EnableCoreSchedIfSupported() (bool, string)

+ func GetCPUInfoPath() string

+ func GetContainerPGIDs(containerParentDir string) ([]uint32, error)

+ func GetIsStartColdMemory() bool

+ func GetIsSupportColdMemory() bool

+ func GetKidledColdBoundary() int

+ func GetNUMAHugepagesDir(numaNodeSubDir string) string

+ func GetNUMAHugepagesNrPath(numaNodeSubDir string, page string) string

+ func GetPCIDeviceDir() string

+ func GetPGIDForPID(pid uint32) (uint32, error)

+ func GetPGIDsForPIDs(pids []uint32) ([]uint32, error)

+ func GetProcPIDStatPath(pid uint32) string

+ func GetSchedCore() (bool, error)

+ func GetSysCPUSMTActivePath() string

+ func GetSysIntelPStateNoTurboPath() string

+ func GoWithNewThread(f func() interface{}) interface

+ func IsCoreSchedFeatureEnabled() (bool, error)

+ func IsKidledSupport() bool

+ func MilliCPUToQuota(milliCPULimit int64) int64

+ func MilliCPUToShares(milliCPURequest int64) int64

+ func ParseCgroupProcs(content string) ([]uint32, error)

+ func SetCoreSchedFeatureEnabled() (bool, string)

+ func SetIsStartColdMemory(flag bool)

+ func SetIsSupportColdMemory(flag bool)

+ func SetKidledColdBoundary(boudary int)

+ func SetKidledScanPeriodInSeconds(period uint32) error

+ func SetKidledUseHierarchy(useHierarchy uint8) error

+ func SetSchedCore(enable bool) error

+ type ColdPageInfoByKidled struct

+ Buckets []uint64

+ Cfea []uint64

+ Cfei []uint64

+ Cfua []uint64

+ Cfui []uint64

+ Csea []uint64

+ Csei []uint64

+ Csua []uint64

+ Csui []uint64

+ Dfea []uint64

+ Dfei []uint64

+ Dfua []uint64

+ Dfui []uint64

+ Dsea []uint64

+ Dsei []uint64

+ Dsua []uint64

+ Dsui []uint64

+ PageScans uint64

+ ScanPeriodInSeconds uint64

+ Slab []uint64

+ SlabScans uint64

+ UseHierarchy uint64

+ Version string

+ func ParseMemoryIdlePageStats(content string) (*ColdPageInfoByKidled, error)

+ func (i *ColdPageInfoByKidled) GetColdPageTotalBytes() uint64

type Config

+ DefaultRuntimeType string

+ PouchEndpoint string

+ type CoreSched struct

+ func (c *CoreSched) Get(pidType CoreSchedScopeType, pid uint32) (uint64, error)

+ func (c *CoreSched) Lock()

+ func (c *CoreSched) Unlock()

+ func (s *CoreSched) Assign(pidTypeFrom CoreSchedScopeType, pidFrom uint32, pidTypeTo CoreSchedScopeType, ...) ([]uint32, error)

+ func (s *CoreSched) Clear(pidType CoreSchedScopeType, pid ...uint32) ([]uint32, error)

+ func (s *CoreSched) Clear(pidType CoreSchedScopeType, pids ...uint32) ([]uint32, error)

+ func (s *CoreSched) Create(pidType CoreSchedScopeType, pid uint32) error

+ func (s *CoreSched) Get(pidType CoreSchedScopeType, pid uint32) (uint64, error)

+ func (s *CoreSched) ShareFrom(pidType CoreSchedScopeType, pid uint32) error

+ func (s *CoreSched) ShareTo(pidType CoreSchedScopeType, pid uint32) error

+ type CoreSchedExtendedInterface interface

+ Assign func(pidTypeFrom CoreSchedScopeType, pidFrom uint32, pidTypeTo CoreSchedScopeType, ...) ([]uint32, error)

+ Clear func(pidType CoreSchedScopeType, pids ...uint32) ([]uint32, error)

+ func NewCoreSchedExtended() CoreSchedExtendedInterface

+ func NewFakeCoreSchedExtended(pidToCookie map[uint32]uint64, pidToPGID map[uint32]uint32, ...) CoreSchedExtendedInterface

+ type CoreSchedExtendedResult struct — linux/amd64

+ Error error

+ FailedPIDs []uint32

+ type CoreSchedInterface interface

+ Create func(pidType CoreSchedScopeType, pid uint32) error

+ Get func(pidType CoreSchedScopeType, pid uint32) (uint64, error)

+ ShareFrom func(pidType CoreSchedScopeType, pid uint32) error

+ ShareTo func(pidType CoreSchedScopeType, pid uint32) error

+ func NewCoreSched() CoreSchedInterface

+ type CoreSchedScopeType uint

+ const CoreSchedScopeProcessGroup

+ const CoreSchedScopeThread

+ const CoreSchedScopeThreadGroup

+ type FakeCoreSchedExtended struct

+ CurPID uint32

+ NextCookieID uint64

+ PIDToCookie map[uint32]uint64

+ PIDToError map[uint32]bool

+ PIDToPGID map[uint32]uint32

+ PIDToTGID map[uint32]uint32

+ func (f *FakeCoreSchedExtended) Assign(pidTypeFrom CoreSchedScopeType, pidFrom uint32, pidTypeTo CoreSchedScopeType, ...) ([]uint32, error)

+ func (f *FakeCoreSchedExtended) Clear(pidType CoreSchedScopeType, pids ...uint32) ([]uint32, error)

+ func (f *FakeCoreSchedExtended) Create(pidType CoreSchedScopeType, pid uint32) error

+ func (f *FakeCoreSchedExtended) Get(pidType CoreSchedScopeType, pid uint32) (uint64, error)

+ func (f *FakeCoreSchedExtended) SetCurPID(pid uint32)

+ func (f *FakeCoreSchedExtended) SetNextCookieID(id uint64)

+ func (f *FakeCoreSchedExtended) ShareFrom(pidType CoreSchedScopeType, pid uint32) error

+ func (f *FakeCoreSchedExtended) ShareTo(pidType CoreSchedScopeType, pid uint32) error

type FileTestUtil

+ CleanupFn func(config *Config)

+ func (c *FileTestUtil) SetConf(setFn, cleanupFn func(conf *Config))

+ type KidledConfig struct

+ KidledColdBoundary int

+ ScanPeriodInseconds uint32

+ UseHierarchy uint8

+ func NewDefaultKidledConfig() *KidledConfig

type MemoryStatRaw

+ func (m *MemoryStatRaw) UsageWithPageCache() int64

+ type ProcStat struct

+ Comm string

+ Pgrp uint32

+ Pid uint32

+ Ppid uint32

+ State byte

+ func ParseProcPIDStat(content string) (*ProcStat, error)

type ResctrlSchemataRaw

+ func (r *ResctrlSchemataRaw) Validate() (bool, string)

+ func (r *ResctrlSchemataRaw) ValidateL3() (bool, string)

+ func (r *ResctrlSchemataRaw) ValidateMB() (bool, string)

v1.3.0

Aug 14, 2023

Changes in this version

+ const BlkioIOQoSName

+ const BlkioIOWeightName

+ const CPUMaxBurstName

+ const CPUSharesMaxValue

+ const RuntimeTypeContainerd

+ const RuntimeTypeDocker

+ const RuntimeTypeUnknown

+ const SysNUMASubDir

+ var BlkioIOQoS = DefaultFactory.New(BlkioIOQoSName, CgroupBlkioDir).WithValidator(BlkioIOQoSValidator).WithSupported(SupportedIfFileExistsInRootCgroup(BlkioIOQoSName, CgroupBlkioDir))

+ var BlkioIOQoSValidator = &BlkIORangeValidator

+ var BlkioIOWeight = DefaultFactory.New(BlkioIOWeightName, CgroupBlkioDir).WithValidator(BlkioIOWeightValidator).WithCheckSupported(SupportedIfFileExistsInKubepods).WithCheckOnce(true)

+ var BlkioIOWeightValidator = &BlkIORangeValidator

+ var BlkioTRBpsValidator = &BlkIORangeValidator

+ var BlkioTRIopsValidator = &BlkIORangeValidator

+ var BlkioTWBpsValidator = &BlkIORangeValidator

+ var BlkioTWIopsValidator = &BlkIORangeValidator

+ var CPUBurstV2 = DefaultFactory.NewV2(CPUBurstName, CPUMaxBurstName).WithValidator(CPUMaxBurstValidator).WithCheckSupported(SupportedIfFileExistsInKubepods).WithCheckOnce(true)

+ var CPUMaxBurstValidator = &RangeValidator

+ var PageSize = int64(syscall.Getpagesize())

+ func GetNUMAMemInfoPath(numaNodeSubDir string) string

+ func GetRootCgroupSubfsDir(subfs string) string

+ func GetSysNUMADir() string

+ func SupportedIfFileExistsInRootCgroup(filename string, subfs string) (bool, string)

+ type BlkIORangeValidator struct

+ func (r *BlkIORangeValidator) Validate(value string) (bool, string)

type CgroupDriverType

+ func GetCgroupDriver() CgroupDriverType

+ func GetCgroupDriverFromCgroupName() CgroupDriverType

+ func GetCgroupDriverFromKubelet(nodeName string) (CgroupDriverType, error)

+ func GetCgroupDriverFromKubeletPort(port int) (CgroupDriverType, error)

type CgroupResource

+ CheckOnce bool

+ func (c *CgroupResource) WithCheckOnce(isCheckOnce bool) Resource

type Config

+ RunRootDir string

type FileTestUtil

+ ValidateResource bool

+ func (c *FileTestUtil) SetValidateResource(enabled bool)

+ type Formatter struct

+ ContainerDirFn func(id string) (string, string, error)

+ ContainerIDParser func(basename string) (string, error)

+ ParentDir string

+ PodDirFn func(qos corev1.PodQOSClass, podUID string) string

+ PodIDParser func(basename string) (string, error)

+ QOSDirFn func(qos corev1.PodQOSClass) string

+ func GetCgroupFormatter() Formatter

+ func GetCgroupPathFormatter(driver CgroupDriverType) Formatter

type ResctrlResource

+ func (r *ResctrlResource) WithCheckOnce(isCheckOnce bool) Resource

type Resource

+ WithCheckOnce func(isCheckOnce bool) Resource

type SystemResource

+ CheckOnce bool

+ func (c *SystemResource) WithCheckOnce(isCheckOnce bool) Resource

v1.2.0

Apr 7, 2023

Changes in this version

+ const AMD_VENDOR_ID

+ const ErrCgroupDir

+ const MemcgReapBackGroundFileName

+ const MemcgReaperRelativePath

+ const MemoryNumaStatName

+ var CPUAcctCPUPressureV2 = DefaultFactory.NewV2(CPUAcctCPUPressureName, CPUAcctCPUPressureName).WithSupported(SupportedIfFileExistsInKubepods(CPUAcctCPUPressureName, ""))

+ var CPUAcctIOPressureV2 = DefaultFactory.NewV2(CPUAcctIOPressureName, CPUAcctIOPressureName).WithSupported(SupportedIfFileExistsInKubepods(CPUAcctIOPressureName, ""))

+ var CPUAcctMemoryPressureV2 = DefaultFactory.NewV2(CPUAcctMemoryPressureName, CPUAcctMemoryPressureName).WithSupported(SupportedIfFileExistsInKubepods(CPUAcctMemoryPressureName, ""))

+ var MemcgReapBackGround = NewCommonSystemResource(MemcgReaperRelativePath, MemcgReapBackGroundFileName, GetSysRootDir).WithValidator(MemcgReapBackGroundValidator).WithCheckSupported(SupportedIfFileExists)

+ var MemcgReapBackGroundValidator = &RangeValidator

+ var MemoryNumaStat = DefaultFactory.New(MemoryNumaStatName, CgroupMemDir)

+ var MemoryNumaStatV2 = DefaultFactory.NewV2(MemoryNumaStatName, MemoryNumaStatName)

+ var MinFreeKbytes = NewCommonSystemResource(ProcSysVmRelativePath, MinFreeKbytesFileName, GetProcRootDir).WithValidator(MinFreeKbytesValidator)

+ var WatermarkScaleFactor = NewCommonSystemResource(ProcSysVmRelativePath, WatermarkScaleFactorFileName, GetProcRootDir).WithValidator(WatermarkScaleFactorValidator)

+ func GetProcRootDir() string

+ func GetSysRootDir() string

+ func GetVendorIDByCPUInfo(path string) (string, error)

+ func IsCgroupV2Resource(r Resource) bool

type CgroupResource

+ CgroupVersion CgroupVersion

+ func (c *CgroupResource) GetCgroupVersion() CgroupVersion

+ func (c *CgroupResource) SetCgroupVersion(cv CgroupVersion)

type FileTestUtil

+ func (c *FileTestUtil) ReadCgroupFileContentsInt(taskDir string, r Resource) *int64

+ type NumaMemoryPages struct

+ NumaId int

+ PagesNum uint64

+ func ParseMemoryNumaStat(content string) ([]NumaMemoryPages, error)

+ func ParseMemoryNumaStatV2(content string) ([]NumaMemoryPages, error)

type ResctrlSchemataRaw

+ func (r *ResctrlSchemataRaw) WithMB(valueOrPercent string) *ResctrlSchemataRaw

type Resource

+ func NewCommonSystemResource(relativePath, fileName string, Rootdir func() string) Resource

+ type SystemResource struct

+ CheckSupported func(r Resource, dynamicPath string) (isSupported bool, msg string)

+ FileName string

+ RelativePath string

+ RootDir func() string

+ SupportMsg string

+ Supported *bool

+ Type ResourceType

+ Validator ResourceValidator

+ func (c *SystemResource) IsSupported(dynamicPath string) (bool, string)

+ func (c *SystemResource) IsValid(v string) (bool, string)

+ func (c *SystemResource) Path(dynamicPath string) string

+ func (c *SystemResource) ResourceType() ResourceType

+ func (c *SystemResource) WithCheckSupported(...) Resource

+ func (c *SystemResource) WithSupported(isSupported bool, msg string) Resource

+ func (c *SystemResource) WithValidator(validator ResourceValidator) Resource

v1.1.1

Jan 16, 2023

v1.1.0

Dec 26, 2022

Changes in this version

+ const BlkioTRBpsName

+ const BlkioTRIopsName

+ const BlkioTWBpsName

+ const BlkioTWIopsName

+ const CFSQuotaMinValue

+ const CPUAcctCPUPressureName

+ const CPUAcctIOPressureName

+ const CPUAcctMemoryPressureName

+ const CPUAcctStatName

+ const CPUAcctUsageName

+ const CPUInfoFileName

+ const CPUMaxName

+ const CPUProcsName

+ const CPUSetCPUSEffectiveName

+ const CPUSetCPUSName

+ const CPUSharesMinValue

+ const CPUSharesName

+ const CPUStatName

+ const CPUTasksName

+ const CPUThreadsName

+ const CPUWeightMaxValue

+ const CPUWeightMinValue

+ const CPUWeightName

+ const CgroupCPUAcctDir

+ const CgroupControllersName

+ const CgroupSubtreeControlName

+ const CgroupV2Dir

+ const DefaultCPUCFSPeriod

+ const ErrResourceUnsupportedPrefix

+ const KernelCmdlineFileName

+ const KernelSchedGroupIdentityEnable

+ const L3SchemataPrefix

+ const MbSchemataPrefix

+ const MemoryCurrentName

+ const MemoryHighName

+ const MemoryLimitName

+ const MemoryLimitUnlimitedValue

+ const MemoryLowName

+ const MemoryMaxName

+ const MemoryMinName

+ const MemoryOomGroupName

+ const MemoryPriorityName

+ const MemoryStatName

+ const MemoryUsageName

+ const MemoryUsePriorityOomName

+ const MemoryWmarkMinAdjName

+ const MemoryWmarkRatioName

+ const MemoryWmarkScaleFactorName

+ const ProcMemInfoName

+ const ProcStatName

+ const ResctrlCbmMaskName

+ const ResctrlSchemataName

+ const ResctrlTasksName

+ const SysctlSubDir

+ var CPUAcctCPUPressure = DefaultFactory.New(CPUAcctCPUPressureName, CgroupCPUAcctDir).WithCheckSupported(SupportedIfFileExists)

+ var CPUAcctIOPressure = DefaultFactory.New(CPUAcctIOPressureName, CgroupCPUAcctDir).WithCheckSupported(SupportedIfFileExists)

+ var CPUAcctMemoryPressure = DefaultFactory.New(CPUAcctMemoryPressureName, CgroupCPUAcctDir).WithCheckSupported(SupportedIfFileExists)

+ var CPUAcctStat = DefaultFactory.New(CPUAcctStatName, CgroupCPUAcctDir)

+ var CPUAcctStatV2 = DefaultFactory.NewV2(CPUAcctStatName, CPUStatName)

+ var CPUAcctUsage = DefaultFactory.New(CPUAcctUsageName, CgroupCPUAcctDir)

+ var CPUAcctUsageV2 = DefaultFactory.NewV2(CPUAcctUsageName, CPUStatName)

+ var CPUCFSPeriodV2 = DefaultFactory.NewV2(CPUCFSPeriodName, CPUMaxName)

+ var CPUCFSQuotaV2 = DefaultFactory.NewV2(CPUCFSQuotaName, CPUMaxName)

+ var CPUProcs = DefaultFactory.New(CPUProcsName, CgroupCPUDir)

+ var CPUProcsV2 = DefaultFactory.NewV2(CPUProcsName, CPUProcsName)

+ var CPUSetCPUSValidator = &CPUSetStrValidator

+ var CPUSetEffectiveV2 = DefaultFactory.NewV2(CPUSetCPUSEffectiveName, CPUSetCPUSEffectiveName)

+ var CPUSetV2 = DefaultFactory.NewV2(CPUSetCPUSName, CPUSetCPUSName).WithValidator(CPUSetCPUSValidator)

+ var CPUSharesV2 = DefaultFactory.NewV2(CPUSharesName, CPUWeightName).WithValidator(CPUWeightValidator)

+ var CPUSharesValidator = &RangeValidator

+ var CPUStatV2 = DefaultFactory.NewV2(CPUStatName, CPUStatName)

+ var CPUTasks = DefaultFactory.New(CPUTasksName, CgroupCPUDir)

+ var CPUTasksV2 = DefaultFactory.NewV2(CPUTasksName, CPUThreadsName)

+ var CPUWeightValidator = &RangeValidator

+ var DefaultFactory = NewCgroupResourceFactory()

+ var DefaultRegistry = NewCgroupResourceRegistry()

+ var Jiffies = float64(10 * time.Millisecond)

+ var MemoryHigh = DefaultFactory.New(MemoryHighName, CgroupMemDir).WithValidator(NaturalInt64Validator).WithSupported(SupportedIfFileExistsInKubepods(MemoryHighName, CgroupMemDir))

+ var MemoryHighV2 = DefaultFactory.NewV2(MemoryHighName, MemoryHighName)

+ var MemoryLimitV2 = DefaultFactory.NewV2(MemoryLimitName, MemoryMaxName)

+ var MemoryLow = DefaultFactory.New(MemoryLowName, CgroupMemDir).WithValidator(NaturalInt64Validator).WithSupported(SupportedIfFileExistsInKubepods(MemoryLowName, CgroupMemDir))

+ var MemoryLowV2 = DefaultFactory.NewV2(MemoryLowName, MemoryLowName)

+ var MemoryMin = DefaultFactory.New(MemoryMinName, CgroupMemDir).WithValidator(NaturalInt64Validator).WithSupported(SupportedIfFileExistsInKubepods(MemoryMinName, CgroupMemDir))

+ var MemoryMinV2 = DefaultFactory.NewV2(MemoryMinName, MemoryMinName)

+ var MemoryOomGroup = DefaultFactory.New(MemoryOomGroupName, CgroupMemDir).WithValidator(MemoryOomGroupValidator).WithSupported(SupportedIfFileExistsInKubepods(MemoryOomGroupName, CgroupMemDir))

+ var MemoryOomGroupV2 = DefaultFactory.NewV2(MemoryOomGroupName, MemoryOomGroupName).WithValidator(MemoryOomGroupValidator).WithCheckSupported(SupportedIfFileExists)

+ var MemoryOomGroupValidator = &RangeValidator

+ var MemoryPriority = DefaultFactory.New(MemoryPriorityName, CgroupMemDir).WithValidator(MemoryPriorityValidator).WithSupported(SupportedIfFileExistsInKubepods(MemoryPriorityName, CgroupMemDir))

+ var MemoryPriorityV2 = DefaultFactory.NewV2(MemoryPriorityName, MemoryPriorityName).WithValidator(MemoryPriorityValidator).WithCheckSupported(SupportedIfFileExists)

+ var MemoryPriorityValidator = &RangeValidator

+ var MemoryStat = DefaultFactory.New(MemoryStatName, CgroupMemDir)

+ var MemoryStatV2 = DefaultFactory.NewV2(MemoryStatName, MemoryStatName)

+ var MemoryUsage = DefaultFactory.New(MemoryUsageName, CgroupMemDir)

+ var MemoryUsageV2 = DefaultFactory.NewV2(MemoryUsageName, MemoryCurrentName)

+ var MemoryUsePriorityOom = DefaultFactory.New(MemoryUsePriorityOomName, CgroupMemDir).WithValidator(MemoryUsePriorityOomValidator).WithSupported(SupportedIfFileExistsInKubepods(MemoryUsePriorityOomName, CgroupMemDir))

+ var MemoryUsePriorityOomV2 = DefaultFactory.NewV2(MemoryUsePriorityOomName, MemoryUsePriorityOomName).WithValidator(MemoryUsePriorityOomValidator).WithCheckSupported(SupportedIfFileExists)

+ var MemoryUsePriorityOomValidator = &RangeValidator

+ var MemoryWmarkMinAdj = DefaultFactory.New(MemoryWmarkMinAdjName, CgroupMemDir).WithValidator(MemoryWmarkMinAdjValidator).WithSupported(SupportedIfFileExistsInKubepods(MemoryWmarkMinAdjName, CgroupMemDir))

+ var MemoryWmarkMinAdjV2 = DefaultFactory.NewV2(MemoryWmarkMinAdjName, MemoryWmarkMinAdjName).WithValidator(MemoryWmarkMinAdjValidator).WithCheckSupported(SupportedIfFileExists)

+ var MemoryWmarkMinAdjValidator = &RangeValidator

+ var MemoryWmarkRatio = DefaultFactory.New(MemoryWmarkRatioName, CgroupMemDir).WithValidator(MemoryWmarkRatioValidator).WithSupported(SupportedIfFileExistsInKubepods(MemoryWmarkRatioName, CgroupMemDir))

+ var MemoryWmarkRatioV2 = DefaultFactory.NewV2(MemoryWmarkRatioName, MemoryWmarkRatioName).WithValidator(MemoryWmarkRatioValidator).WithCheckSupported(SupportedIfFileExists)

+ var MemoryWmarkRatioValidator = &RangeValidator

+ var MemoryWmarkScaleFactor = DefaultFactory.New(MemoryWmarkScaleFactorName, CgroupMemDir).WithValidator(MemoryWmarkScaleFactorFileNameValidator).WithSupported(SupportedIfFileExistsInKubepods(MemoryWmarkScaleFactorName, CgroupMemDir))

+ var MemoryWmarkScaleFactorFileNameValidator = &RangeValidator

+ var MemoryWmarkScaleFactorV2 = DefaultFactory.NewV2(MemoryWmarkScaleFactorName, MemoryWmarkScaleFactorName).WithValidator(MemoryWmarkScaleFactorFileNameValidator).WithCheckSupported(SupportedIfFileExists)

+ var NaturalInt64Validator = &RangeValidator

+ var ResctrlL3CbmMask = NewCommonResctrlResource(ResctrlCbmMaskName, filepath.Join(RdtInfoDir, L3CatDir))

+ var ResctrlSchemata = NewCommonResctrlResource(ResctrlSchemataName, "")

+ var ResctrlTasks = NewCommonResctrlResource(ResctrlTasksName, "")

+ var UseCgroupsV2 bool

+ func CalculateCatL3MaskValue(cbm uint, startPercent, endPercent int64) (string, error)

+ func CheckIfAllSupported(checkSupportedFns ...func() (bool, string)) func() (bool, string)

+ func ConvertCPUSharesToWeight(s string) (int64, error)

+ func ConvertCPUWeightToShares(v int64) (int64, error)

+ func GetCacheInfo(str string) (string, int32, error)

+ func GetKubeletCommandline(port int) ([]string, error)

+ func GetPeriodTicks(start, end time.Time) float64

+ func GetProcFilePath(file string) string

+ func GetProcSysFilePath(file string) string

+ func InitCatGroupIfNotExist(group string) error

+ func IsResourceUnsupportedErr(err error) bool

+ func IsSupportResctrl() (bool, error)

+ func IsUsingCgroupsV2() bool

+ func KubeletPortToPid(port int) (int, error) — linux/amd64

+ func NewProcSysctl() utilsysctl.Interface

+ func ParseCPUAcctUsageV2(content string) (uint64, error)

+ func ParseCPUCFSPeriodV2(content string) (int64, error)

+ func ParseCPUCFSQuotaV2(content string) (int64, error)

+ func ParseKVMap(content string) map[string]string

+ func ParseResctrlSchemataMap(content string) map[string]map[int]string

+ func ReadCgroupAndParseInt32Slice(parentDir string, r Resource) ([]int32, error)

+ func ReadCgroupAndParseInt64(parentDir string, r Resource) (int64, error)

+ func ReadCgroupAndParseUint64(parentDir string, r Resource) (uint64, error)

+ func ResourceUnsupportedErr(msg string) error

+ func SetSchedGroupIdentity(enable bool) error

+ func SupportedIfFileExists(r Resource, parentDir string) (bool, string)

+ func SupportedIfFileExistsInKubepods(filename string, subfs string) (bool, string)

+ func TCPSocks(fn netstat.AcceptFn) ([]netstat.SockTabEntry, error) — linux/amd64

+ func ValidateResourceValue(value *int64, parentDir string, r Resource) bool

+ func WorkingDirOf(pid int) (string, error)

+ type CPUSetStrValidator struct

+ func (c *CPUSetStrValidator) Validate(value string) (bool, string)

type CPUStatRaw

+ NrPeriods int64

+ func ParseCPUStatRaw(content string) (*CPUStatRaw, error)

+ func ParseCPUStatRawV2(content string) (*CPUStatRaw, error)

+ func ReadCPUStatRaw(cgroupPath string) (*CPUStatRaw, error)

+ type CPUStatV2Raw struct

+ NrPeriods int64

+ NrThrottled int64

+ SystemUSec int64

+ ThrottledUSec int64

+ UsageUsec int64

+ UserUsec int64

+ func ParseCPUAcctStatRawV2(content string) (*CPUStatV2Raw, error)

type CgroupDriverType — darwin/amd64, js/wasm, windows/amd64

+ func GuessCgroupDriverFromKubeletPort(int) (CgroupDriverType, error)

type CgroupDriverType — linux/amd64

+ func GuessCgroupDriverFromKubeletPort(port int) (CgroupDriverType, error)

+ type CgroupResource struct

+ CheckSupported func(r Resource, parentDir string) (isSupported bool, msg string)

+ FileName string

+ Subfs string

+ SupportMsg string

+ Supported *bool

+ Type ResourceType

+ Validator ResourceValidator

+ func (c *CgroupResource) IsSupported(parentDir string) (bool, string)

+ func (c *CgroupResource) IsValid(v string) (bool, string)

+ func (c *CgroupResource) Path(parentDir string) string

+ func (c *CgroupResource) ResourceType() ResourceType

+ func (c *CgroupResource) WithCheckSupported(...) Resource

+ func (c *CgroupResource) WithSupported(isSupported bool, msg string) Resource

+ func (c *CgroupResource) WithValidator(validator ResourceValidator) Resource

+ type CgroupResourceFactory interface

+ New func(filename string, subfs string) Resource

+ NewV2 func(t ResourceType, filename string) Resource

+ func NewCgroupResourceFactory() CgroupResourceFactory

+ type CgroupResourceRegistry interface

+ Add func(v CgroupVersion, s ...Resource)

+ Get func(v CgroupVersion, t ResourceType) (Resource, bool)

+ func NewCgroupResourceRegistry() CgroupResourceRegistry

+ type CgroupResourceRegistryImpl struct

+ func (r *CgroupResourceRegistryImpl) Add(v CgroupVersion, s ...Resource)

+ func (r *CgroupResourceRegistryImpl) Get(v CgroupVersion, key ResourceType) (Resource, bool)

+ type CgroupVersion int32

+ const CgroupVersionV1

+ const CgroupVersionV2

+ func GetCurrentCgroupVersion() CgroupVersion

type Config

+ RuntimeHooksConfigDir string

type FileTestUtil

+ func (c *FileTestUtil) SetAnolisOSResourcesSupported(supported bool)

+ func (c *FileTestUtil) SetCgroupsV2(useCgroupsV2 bool)

+ func (c *FileTestUtil) SetResourcesSupported(supported bool, resources ...Resource)

+ type MemoryStatRaw struct

+ ActiveAnon int64

+ ActiveFile int64

+ Cache int64

+ InactiveAnon int64

+ InactiveFile int64

+ RSS int64

+ Unevictable int64

+ func ParseMemoryStatRaw(content string) (*MemoryStatRaw, error)

+ func ParseMemoryStatRawV2(content string) (*MemoryStatRaw, error)

+ func (m *MemoryStatRaw) Usage() int64

+ type PSILine struct

+ Avg10 float64

+ Avg300 float64

+ Avg60 float64

+ Total uint64

+ type PSIStats struct

+ Full *PSILine

+ FullSupported bool

+ Some *PSILine

+ func ReadPSI(pressureFilePath string) (PSIStats, error)

+ type ProcSysctl struct

+ func (*ProcSysctl) GetSysctl(sysctl string) (int, error)

+ func (*ProcSysctl) SetSysctl(sysctl string, newVal int) error

+ type ResctrlResource struct

+ CheckSupported func(r Resource, parentDir string) (isSupported bool, msg string)

+ FileName string

+ Subdir string

+ Type ResourceType

+ Validator ResourceValidator

+ func (r *ResctrlResource) IsSupported(parentDir string) (bool, string)

+ func (r *ResctrlResource) IsValid(v string) (bool, string)

+ func (r *ResctrlResource) Path(parentDir string) string

+ func (r *ResctrlResource) ResourceType() ResourceType

+ func (r *ResctrlResource) WithCheckSupported(...) Resource

+ func (r *ResctrlResource) WithSupported(isSupported bool, msg string) Resource

+ func (r *ResctrlResource) WithValidator(validator ResourceValidator) Resource

+ type ResctrlSchemataRaw struct

+ L3 []int64

+ L3Num int

+ MB []int64

+ func NewResctrlSchemataRaw() *ResctrlSchemataRaw

+ func ReadResctrlSchemataRaw(schemataFile string, l3Num int) (*ResctrlSchemataRaw, error)

+ func (r *ResctrlSchemataRaw) DeepCopy() *ResctrlSchemataRaw

+ func (r *ResctrlSchemataRaw) Equal(a *ResctrlSchemataRaw) (bool, string)

+ func (r *ResctrlSchemataRaw) L3Number() int

+ func (r *ResctrlSchemataRaw) L3String() string

+ func (r *ResctrlSchemataRaw) MBString() string

+ func (r *ResctrlSchemataRaw) ParseResctrlSchemata(content string, l3Num int) error

+ func (r *ResctrlSchemataRaw) Prefix() string

+ func (r *ResctrlSchemataRaw) WithL3Mask(mask string) *ResctrlSchemataRaw

+ func (r *ResctrlSchemataRaw) WithL3Num(l3Num int) *ResctrlSchemataRaw

+ func (r *ResctrlSchemataRaw) WithMBPercent(percent string) *ResctrlSchemataRaw

+ type Resource interface

+ IsSupported func(parentDir string) (bool, string)

+ IsValid func(v string) (bool, string)

+ Path func(parentDir string) string

+ ResourceType func() ResourceType

+ WithCheckSupported func(...) Resource

+ WithSupported func(supported bool, msg string) Resource

+ WithValidator func(validator ResourceValidator) Resource

+ func GetCgroupResource(resourceType ResourceType) (Resource, error)

+ func NewCommonCgroupResource(resourceType ResourceType, filename string, subfs string) Resource

+ func NewCommonResctrlResource(filename string, subdir string) Resource

+ type ResourceType string

+ func GetDefaultResourceType(subfs string, filename string) ResourceType

+ type ResourceValidator interface

+ Validate func(value string) (isValid bool, msg string)

type VersionInfo

+ IsAnolisOS bool

v0

v0.1.0

Apr 1, 2022

Changes in this version

+ const BandwidthCtrlQdiscCount — linux/amd64

+ const BlkioTRBpsFileName

+ const BlkioTRIopsFileName

+ const BlkioTWBpsFileName

+ const BlkioTWIopsFileName

+ const CFSBasePeriodValue

+ const CFSQuotaUnlimitedValue

+ const CPUBVTWarpNsName

+ const CPUBurstName

+ const CPUBvtBEValue

+ const CPUBvtLSValue

+ const CPUCFSPeriodName

+ const CPUCFSQuotaName

+ const CPUSFileName

+ const CPUShareKubeBEValue

+ const CPUShareUnitValue

+ const CPUSharesFileName

+ const CPUStatFileName

+ const CPUTaskFileName

+ const CbmMaskFileName

+ const CgroupBlkioDir

+ const CgroupCPUDir

+ const CgroupCPUSetDir

+ const CgroupCPUacctDir

+ const CgroupMaxSymbolStr

+ const CgroupMaxValueStr

+ const CgroupMemDir

+ const CgroupNetClsDir

+ const Cgroupfs

+ const CopperDSCP

+ const CopperNetClsID

+ const CpuacctProcStatFileName

+ const CpuacctProcStatV2FileName

+ const CpuacctStatFileName

+ const DS_MODE

+ const DefaultIfaceBandwidth — linux/amd64

+ const Devices

+ const EmptyValueError

+ const GoldDSCP

+ const GoldNetClsID

+ const HOST_MODE

+ const KubeBesteffortNameCgroupfs

+ const KubeBesteffortNameSystemd

+ const KubeBurstableNameCgroupfs

+ const KubeBurstableNameSystemd

+ const KubeRootNameCgroupfs

+ const KubeRootNameSystemd

+ const L3CatDir

+ const MemDroppableFileName

+ const MemFlagsFileName

+ const MemHighFileName

+ const MemLowFileName

+ const MemMinFileName

+ const MemOomGroupFileName

+ const MemPriorityFileName

+ const MemStatFileName

+ const MemUsePriorityOomFileName

+ const MemWmarkMinAdjFileName

+ const MemWmarkRatioFileName

+ const MemWmarkScaleFactorFileName

+ const MemoryLimitFileName

+ const MemorySWLimitFileName

+ const MemoryUnlimitValue

+ const MinFreeKbytesFileName

+ const NetClsIDFileName

+ const ProcStatFileName

+ const ProcSysVmRelativePath

+ const QosctlBinaryPath — linux/amd64

+ const QosctlPackageName — linux/amd64

+ const RdtInfoDir

+ const ResctrlDir

+ const ResctrlName

+ const ResctrlTaskFileName

+ const SchemataFileName

+ const SilverDSCP

+ const SilverNetClsID

+ const Systemd

+ const WatermarkScaleFactorFileName

+ var AgentMode = DS_MODE

+ var BlkioReadBps = CgroupFile

+ var BlkioReadIops = CgroupFile

+ var BlkioWriteBps = CgroupFile

+ var BlkioWriteIops = CgroupFile

+ var CPUBVTWarpNs = CgroupFile

+ var CPUBurst = CgroupFile

+ var CPUBurstValidator = &RangeValidator

+ var CPUBvtWarpNsValidator = &RangeValidator

+ var CPUCFSPeriod = CgroupFile

+ var CPUCFSQuota = CgroupFile

+ var CPUSet = CgroupFile

+ var CPUShares = CgroupFile

+ var CPUStat = CgroupFile

+ var CPUTask = CgroupFile

+ var CgroupPathFormatter = cgroupPathFormatterInSystemd

+ var CommonRootDir = ""

+ var Conf = NewDsModeConfig()

+ var CpuacctProcStat = CgroupFile

+ var CpuacctProcStatV2 = CgroupFile

+ var CpuacctStat = CgroupFile

+ var EnsureQosctlReady = ensureQosctlReadyFn

+ var ExecCmdOnHost = execCmdOnHostFn

+ var GetHostDefaultIface = getHostDefaultIfaceFn

+ var GetIfaceSpeedMbit = getIfaceSpeedMbitFn

+ var HostSystemInfo = collectVersionInfo()

+ var MemDroppable = CgroupFile

+ var MemDroppableValidator = &RangeValidator

+ var MemFlags = CgroupFile

+ var MemHigh = CgroupFile

+ var MemHighValidator = &RangeValidator

+ var MemLow = CgroupFile

+ var MemLowValidator = &RangeValidator

+ var MemMin = CgroupFile

+ var MemMinValidator = &RangeValidator

+ var MemOomGroup = CgroupFile

+ var MemOomGroupValidator = &RangeValidator

+ var MemPriority = CgroupFile

+ var MemPriorityValidator = &RangeValidator

+ var MemStat = CgroupFile

+ var MemUsePriorityOom = CgroupFile

+ var MemUsePriorityOomValidator = &RangeValidator

+ var MemWmarkMinAdj = CgroupFile

+ var MemWmarkMinAdjValidator = &RangeValidator

+ var MemWmarkRatio = CgroupFile

+ var MemWmarkRatioValidator = &RangeValidator

+ var MemWmarkScaleFactor = CgroupFile

+ var MemWmarkScaleFactorFileNameValidator = &RangeValidator

+ var MemoryLimit = CgroupFile

+ var MemorySWLimit = CgroupFile

+ var MinFreeKbytesValidator = &RangeValidator

+ var NetClsID = CgroupFile

+ var PidOf = pidOfFn

+ var QosctlKModsRegex = []*regexp.Regexp — linux/amd64

+ var SetupBandwidthCtrl = setupBandwidthCtrlFn

+ var WatermarkScaleFactorValidator = &RangeValidator

+ func CPUIdentityEnabled() (bool, error)

+ func CalcCPUThrottledRatio(curPoint, prePoint *CPUStatRaw) float64

+ func CgroupFileRead(cgroupTaskDir string, file CgroupFile) (string, error)

+ func CgroupFileReadInt(cgroupTaskDir string, file CgroupFile) (*int64, error)

+ func CgroupFileWrite(cgroupTaskDir string, file CgroupFile, data string) error

+ func CgroupFileWriteIfDifferent(cgroupTaskDir string, file CgroupFile, value string) error

+ func CheckAndTryEnableResctrlCat() error

+ func CommonFileRead(file string) (string, error)

+ func CommonFileWrite(file string, data string) error

+ func CommonFileWriteIfDifferent(file string, value string) error

+ func FileExists(path string) bool

+ func GetCgroupCurTasks(cgroupPath string) ([]int, error)

+ func GetCgroupFilePath(cgroupTaskDir string, file CgroupFile) string

+ func GetResctrlGroupRootDirPath(groupPath string) string

+ func GetResctrlL3CbmFilePath() string

+ func GetResctrlSchemataFilePath(groupPath string) string

+ func GetResctrlSubsystemDirPath() string

+ func GetResctrlTasksFilePath(groupPath string) string

+ func HasBandwidthCtrlSetup(iface *net.Interface) bool

+ func Int64Ptr(v int64) *int64

+ func MountResctrlSubsystem() (bool, error)

+ func PathExists(path string) (bool, error)

+ func ProcCmdLine(procRoot string, pid int) ([]string, error)

+ func ReadCatL3Cbm() (uint, error)

+ func ReadCatL3CbmString() (string, error)

+ func ReadFileNoStat(filename string) ([]byte, error)

+ func ReadResctrlTasksMap(groupPath string) (map[int]struct{}, error)

+ func ResetBandwidthCtrl(iface *net.Interface)

+ func SetConf(config Config)

+ func SetupCgroupPathFormatter(driver CgroupDriverType)

+ func ValidateCgroupValue(value *int64, parentDir string, file CgroupFile) bool

+ func ValidateValue(value *int64, file SystemFile) bool

+ type BandwidthConfig struct

+ CopperDSCP uint64

+ CopperLimit uint64

+ CopperRequest uint64

+ GatewayIfaceName string

+ GatewayLimit uint64

+ GoldDSCP uint64

+ GoldLimit uint64

+ GoldRequest uint64

+ RootLimit uint64

+ SilverDSCP uint64

+ SilverLimit uint64

+ SilverRequest uint64

+ type CPUStatRaw struct

+ NrPeriod int64

+ NrThrottled int64

+ ThrottledNanoSeconds int64

+ func GetCPUStatRaw(cgroupPath string) (*CPUStatRaw, error)

+ type CgroupDriverType string

+ func GuessCgroupDriverFromCgroupName() CgroupDriverType

+ func GuessCgroupDriverFromKubelet() (CgroupDriverType, error)

+ func (c CgroupDriverType) Validate() bool

+ type CgroupFile struct

+ IsAliOS bool

+ ResourceFileName string

+ Subfs string

+ Validator Validate

+ type Config struct

+ CgroupKubePath string

+ CgroupRootDir string

+ ContainerdEndPoint string

+ DockerEndPoint string

+ NodeNameOverride string

+ ProcRootDir string

+ SysFSRootDir string

+ SysRootDir string

+ VarRunRootDir string

+ func NewDsModeConfig() *Config

+ func NewHostModeConfig() *Config

+ func (c *Config) InitFlags(fs *flag.FlagSet)

+ type FileTestUtil struct

+ TempDir string

+ func NewFileTestUtil(t *testing.T) *FileTestUtil

+ func (c *FileTestUtil) Cleanup()

+ func (c *FileTestUtil) CreateCgroupFile(taskDir string, file CgroupFile)

+ func (c *FileTestUtil) CreateFile(fileRelativePath string)

+ func (c *FileTestUtil) CreateFiles(files []string)

+ func (c *FileTestUtil) CreateProcSubFile(fileRelativePath string)

+ func (c *FileTestUtil) GetAbsoluteFilePath(fileRelativePath string) string

+ func (c *FileTestUtil) MkDirAll(dirRelativePath string)

+ func (c *FileTestUtil) MkProcSubDirAll(dirRelativePath string)

+ func (c *FileTestUtil) ReadCgroupFileContents(taskDir string, file CgroupFile) string

+ func (c *FileTestUtil) ReadFileContents(fileRelativePath string) string

+ func (c *FileTestUtil) ReadProcSubFileContents(relativeFilePath string) string

+ func (c *FileTestUtil) WriteCgroupFileContents(taskDir string, file CgroupFile, contents string)

+ func (c *FileTestUtil) WriteFileContents(fileRelativePath, contents string)

+ func (c *FileTestUtil) WriteProcSubFileContents(relativeFilePath string, contents string)

+ type NetworkTestUtil struct

+ func NewNetworkTestUtil(t *testing.T) *NetworkTestUtil

+ func (n *NetworkTestUtil) Cleanup()

+ func (n *NetworkTestUtil) SetupDummyLinkWithAddr() *netlink.Dummy

+ type RangeValidator struct

+ func (r *RangeValidator) Validate(value *int64) (isValid bool, msg string)

+ type SystemFile struct

+ File string

+ Validator Validate

+ var MinFreeKbytesFile SystemFile

+ var ProcStatFile SystemFile

+ var WatermarkScaleFactorFile SystemFile

+ type Validate interface

+ Validate func(value *int64) (isValid bool, msg string)

+ type VersionInfo struct

+ IsAliOS bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL