plugin

Documentation

Index

• Constants
• func DummyTMOBlockFn(ci *types.ContainerInfo, conf interface{}) bool
• func GetRegisteredInitializers() map[types.MemoryAdvisorPluginName]InitFunc
• func NewTmoEngineInstance(obj interface{}, metaServer *metaserver.MetaServer, ...) *tmoEngineInstance
• func RegisterInitializer(name types.MemoryAdvisorPluginName, initFunc InitFunc)
• func RegisterTMOBlockFunc(blockFnName string, blockFn TMOBlockFn)
• func RegisterTMOPolicyFunc(policyName v1alpha1.TMOPolicyName, tmoPolicyFn TmoPolicyFn)
• type BalanceInfo
• type BalanceLevel
• type BalancePod
• type BalanceStatus
• type BandwidthLevel
• type EvictPod
• type InitFunc
• type MemoryAdvisorPlugin
  • func NewCacheReaper(conf *config.Configuration, extraConfig interface{}, ...) MemoryAdvisorPlugin
  • func NewMemoryBalancer(conf *config.Configuration, _ interface{}, metaReader metacache.MetaReader, ...) MemoryAdvisorPlugin
  • func NewMemoryGuard(conf *config.Configuration, extraConfig interface{}, ...) MemoryAdvisorPlugin
  • func NewMemsetBinder(conf *config.Configuration, extraConfig interface{}, ...) MemoryAdvisorPlugin
  • func NewTransparentMemoryOffloading(conf *config.Configuration, extraConfig interface{}, ...) MemoryAdvisorPlugin
• type NumaInfo
• type NumaLatencyInfo
• type PodSort
• type TMOBlockFn
• type TmoEngine
• type TmoPolicyFn
• type TmoStats

Constants

const (
	NumaMemoryBalancer               = "numa_memory_balancer"
	EvictionPluginNameMemoryBalancer = "numa_memory_balancer"

	EvictReason = "the memory node %v is under bandwidth pressure"

	MetricNumaMemoryBalance = "numa_memory_balance"
)

const (
	BandwidthHighThreshold   float64 = 0.8
	BandwidthMediumThreshold float64 = 0.5

	PingPongDetectThresholdInMinutes = 15

	MigratePagesThreshold = 0.7
	BalanceInterval       = 30 * time.Second
)

const (
	InactiveProbe            = 0.1
	OffloadingSizeScaleCoeff = 1.05
)

const (
	CacheReaper = "cache-reaper"
)

const (
	DummyTMOBlockFnName string = "dummy-tmo-block-fn"
)

const (
	MemoryGuard = "memory-guard"
)

const (
	MemsetBinder = "memset-binder"
)

const (
	TransparentMemoryOffloading = "transparent-memory-offloading"
)

Functions

func DummyTMOBlockFn

func DummyTMOBlockFn(ci *types.ContainerInfo, conf interface{}) bool

func GetRegisteredInitializers

func GetRegisteredInitializers() map[types.MemoryAdvisorPluginName]InitFunc

func NewTmoEngineInstance

func NewTmoEngineInstance(obj interface{}, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter, tmoConf *tmo.TransparentMemoryOffloadingConfiguration) *tmoEngineInstance

func RegisterInitializer

func RegisterInitializer(name types.MemoryAdvisorPluginName, initFunc InitFunc)

func RegisterTMOBlockFunc

func RegisterTMOBlockFunc(blockFnName string, blockFn TMOBlockFn)

func RegisterTMOPolicyFunc

func RegisterTMOPolicyFunc(policyName v1alpha1.TMOPolicyName, tmoPolicyFn TmoPolicyFn)

Types

type BalanceInfo

type BalanceInfo struct {
	EvictPods                    []EvictPod         `json:"evictPods"`
	BalancePods                  []BalancePod       `json:"balancePods"`
	DestNumas                    []NumaInfo         `json:"destNumas"`
	NeedBalance                  bool               `json:"needBalance"`
	BandwidthPressure            bool               `json:"bandwidthPressure"`
	BalanceLevel                 BalanceLevel       `json:"balanceLevel"`
	TotalRSS                     float64            `json:"totalRSS"`
	MaxLatencyNuma               *NumaLatencyInfo   `json:"maxLatencyNuma"`
	MaxBandwidthNuma             *NumaLatencyInfo   `json:"maxBandwidthNuma"`
	RawNumaLatencyInfo           []*NumaLatencyInfo `json:"rawNumaLatencyInfo"`
	MaxLatencyNumaBandwidthLevel BandwidthLevel     `json:"maxLatencyNumaBandwidthLevel"`
	SourceNuma                   *NumaLatencyInfo   `json:"sourceNuma"`
	Status                       BalanceStatus      `json:"status"`
	FailedReason                 string             `json:"failedReason"`
	DetectTime                   time.Time          `json:"detectTime"`
	BalanceExecuted              bool               `json:"balanceExecuted"`
	EvictExecuted                bool               `json:"evictExecuted"`
}

type BalanceLevel

type BalanceLevel string

const (
	ForceBalance BalanceLevel = "forceBalance"
	GraceBalance BalanceLevel = "graceBalance"
)

type BalancePod

type BalancePod struct {
	Namespace       string   `json:"namespace"`
	Name            string   `json:"name"`
	UID             string   `json:"UID"`
	Containers      []string `json:"containers"`
	RSSOnSourceNuma float64  `json:"RSSOnSourceNuma"`
	DestNumas       []int    `json:"destNumas"`
}

type BalanceStatus

type BalanceStatus string

const (
	BalanceStatusPreparing      BalanceStatus = "preparing"
	BalanceStatusPrepareSuccess BalanceStatus = "prepareSuccess"
	BalanceStatusPrepareFailed  BalanceStatus = "prepareFailed"
)

type BandwidthLevel

type BandwidthLevel string

const (
	BandwidthLevelLow    BandwidthLevel = "low"
	BandwidthLevelMedium BandwidthLevel = "medium"
	BandwidthLevelHigh   BandwidthLevel = "high"
)

type EvictPod

type EvictPod struct {
	Namespace string `json:"namespace"`
	Name      string `json:"name"`
	UID       string `json:"UID"`
}

type InitFunc

type InitFunc func(conf *config.Configuration, extraConfig interface{}, metaReader metacache.MetaReader,
	metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter) MemoryAdvisorPlugin

type MemoryAdvisorPlugin

type MemoryAdvisorPlugin interface {
	// Reconcile triggers an episode of plugin update
	Reconcile(status *types.MemoryPressureStatus) error
	// GetAdvices return the advices
	GetAdvices() types.InternalMemoryCalculationResult
}

MemoryAdvisorPlugin generates resource provision result based on configured algorithm

func NewCacheReaper

func NewCacheReaper(conf *config.Configuration, extraConfig interface{}, metaReader metacache.MetaReader, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter) MemoryAdvisorPlugin

func NewMemoryBalancer

func NewMemoryBalancer(conf *config.Configuration, _ interface{}, metaReader metacache.MetaReader, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter) MemoryAdvisorPlugin

func NewMemoryGuard

func NewMemoryGuard(conf *config.Configuration, extraConfig interface{}, metaReader metacache.MetaReader, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter) MemoryAdvisorPlugin

func NewMemsetBinder

func NewMemsetBinder(conf *config.Configuration, extraConfig interface{}, metaReader metacache.MetaReader, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter) MemoryAdvisorPlugin

func NewTransparentMemoryOffloading

func NewTransparentMemoryOffloading(conf *config.Configuration, extraConfig interface{}, metaReader metacache.MetaReader, metaServer *metaserver.MetaServer, emitter metrics.MetricEmitter) MemoryAdvisorPlugin

type NumaInfo

type NumaInfo struct {
	*NumaLatencyInfo
	Distance int `json:"Distance"`
}

type NumaLatencyInfo

type NumaLatencyInfo struct {
	NumaID             int     `json:"NumaID"`
	ReadLatency        float64 `json:"ReadLatency"`
	ReadWriteBandwidth float64 `json:"ReadWriteBandwidth"`
}

type PodSort

type PodSort struct {
	Pod          *v1.Pod
	DestNumaList []int
	SortValue    float64
}

type TMOBlockFn

type TMOBlockFn func(ci *types.ContainerInfo, conf interface{}) bool

type TmoEngine

type TmoEngine interface {
	GetContainerInfo() *types.ContainerInfo
	GetCgpath() string
	LoadConf(*tmo.TMOConfigDetail)
	GetConf() *tmo.TMOConfigDetail
	CalculateOffloadingTargetSize()
	GetOffloadingTargetSize() float64
}

type TmoPolicyFn

type TmoPolicyFn func(
	lastStats TmoStats,
	currStats TmoStats,
	conf *tmoconf.TMOConfigDetail) (error, float64)

type TmoStats

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