resmanager

Documentation

Index

• Constants
• type CPUBurst
  • func NewCPUBurst(r *resmanager) *CPUBurst
  • func (b *CPUBurst) Recycle()
• type CPUEvictor
  • func NewCPUEvictor(resmanager *resmanager) *CPUEvictor
• type CPUSuppress
  • func NewCPUSuppress(r *resmanager) *CPUSuppress
  • func (r *CPUSuppress) RunInit(stopCh <-chan struct{}) error
• type CgroupResourcesReconcile
  • func NewCgroupResourcesReconcile(resmanager *resmanager) *CgroupResourcesReconcile
  • func (m *CgroupResourcesReconcile) RunInit(stopCh <-chan struct{}) error
• type Config
  • func NewDefaultConfig() *Config
  • func (c *Config) InitFlags(fs *flag.FlagSet)
• type MemoryEvictor
  • func NewMemoryEvictor(mgr *resmanager) *MemoryEvictor
• type ResManager
  • func NewResManager(cfg *Config, schema *apiruntime.Scheme, kubeClient clientset.Interface, ...) ResManager
• type ResctrlReconcile
  • func NewResctrlReconcile(resManager *resmanager) *ResctrlReconcile
  • func (r *ResctrlReconcile) RunInit(stopCh <-chan struct{}) error

Constants

const (
	// LSRResctrlGroup is the name of LSR resctrl group
	LSRResctrlGroup = "LSR"
	// LSResctrlGroup is the name of LS resctrl group
	LSResctrlGroup = "LS"
	// BEResctrlGroup is the name of BE resctrl group
	BEResctrlGroup = "BE"
	// UnknownResctrlGroup is the resctrl group which is unknown to reconcile
	UnknownResctrlGroup = "Unknown"
)

Types

type CPUBurst

type CPUBurst struct {
	// contains filtered or unexported fields
}

func NewCPUBurst

func NewCPUBurst(r *resmanager) *CPUBurst

func (*CPUBurst) Recycle

func (b *CPUBurst) Recycle()

type CPUEvictor

type CPUEvictor struct {
	// contains filtered or unexported fields
}

func NewCPUEvictor

func NewCPUEvictor(resmanager *resmanager) *CPUEvictor

type CPUSuppress

type CPUSuppress struct {
	// contains filtered or unexported fields
}

func NewCPUSuppress

func NewCPUSuppress(r *resmanager) *CPUSuppress

func (*CPUSuppress) RunInit

func (r *CPUSuppress) RunInit(stopCh <-chan struct{}) error

type CgroupResourcesReconcile

type CgroupResourcesReconcile struct {
	// contains filtered or unexported fields
}

func NewCgroupResourcesReconcile

func NewCgroupResourcesReconcile(resmanager *resmanager) *CgroupResourcesReconcile

func (*CgroupResourcesReconcile) RunInit

func (m *CgroupResourcesReconcile) RunInit(stopCh <-chan struct{}) error

type Config

type Config struct {
	ReconcileIntervalSeconds   int
	CPUSuppressIntervalSeconds int
	CPUEvictIntervalSeconds    int
	MemoryEvictIntervalSeconds int
	MemoryEvictCoolTimeSeconds int
	CPUEvictCoolTimeSeconds    int
	QOSExtensionCfg            *plugins.QOSExtensionConfig
}

func NewDefaultConfig

func NewDefaultConfig() *Config

func (*Config) InitFlags

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

type MemoryEvictor

type MemoryEvictor struct {
	// contains filtered or unexported fields
}

func NewMemoryEvictor

func NewMemoryEvictor(mgr *resmanager) *MemoryEvictor

type ResManager

type ResManager interface {
	Run(stopCh <-chan struct{}) error
}

func NewResManager

func NewResManager(cfg *Config, schema *apiruntime.Scheme, kubeClient clientset.Interface, crdClient *koordclientset.Clientset, nodeName string,
	statesInformer statesinformer.StatesInformer, metricCache metriccache.MetricCache, collectResUsedIntervalSeconds int64) ResManager

type ResctrlReconcile

type ResctrlReconcile struct {
	// contains filtered or unexported fields
}

func NewResctrlReconcile

func NewResctrlReconcile(resManager *resmanager) *ResctrlReconcile

func (*ResctrlReconcile) RunInit

func (r *ResctrlReconcile) RunInit(stopCh <-chan struct{}) error