strategy

Documentation

Index

• type CPUPressureEviction
• type CPUPressureForceEviction
  • func NewCPUPressureSuppressionEviction(_ metrics.MetricEmitter, _ *metaserver.MetaServer, conf *config.Configuration, ...) CPUPressureForceEviction
• type CPUPressureLoadEviction
  • func (p *CPUPressureLoadEviction) GetTopEvictionPods(_ context.Context, request *pluginapi.GetTopEvictionPodsRequest) (*pluginapi.GetTopEvictionPodsResponse, error)
  • func (p *CPUPressureLoadEviction) Name() string
  • func (p *CPUPressureLoadEviction) Start(ctx context.Context) (err error)
  • func (p *CPUPressureLoadEviction) ThresholdMet(_ context.Context, _ *pluginapi.Empty) (*pluginapi.ThresholdMetResponse, error)
• type CPUPressureSuppression
  • func (p *CPUPressureSuppression) GetEvictPods(_ context.Context, request *pluginapi.GetEvictPodsRequest) (*pluginapi.GetEvictPodsResponse, error)
  • func (p *CPUPressureSuppression) Name() string
  • func (p *CPUPressureSuppression) Start(context.Context) error
• type CPUPressureThresholdEviction
  • func NewCPUPressureEviction(emitter metrics.MetricEmitter, metaServer *metaserver.MetaServer, ...) CPUPressureThresholdEviction
• type Entries
• type MetricInfo
• type MetricRing
  • func CreateMetricRing(size int) *MetricRing
  • func (ring *MetricRing) Count() (softOverCount, hardOverCount int)
  • func (ring *MetricRing) Push(snapShot *MetricSnapshot)
  • func (ring *MetricRing) Sum() float64
• type MetricSnapshot
• type PoolMetricCollectHandler
• type SubEntries
  • func (se SubEntries) IsPoolEntry() bool

Types

type CPUPressureEviction

type CPUPressureEviction interface {
	Start(context.Context) (err error)
	Name() string
}

type CPUPressureForceEviction

type CPUPressureForceEviction interface {
	CPUPressureEviction
	GetEvictPods(context.Context, *pluginapi.GetEvictPodsRequest) (*pluginapi.GetEvictPodsResponse, error)
}

func NewCPUPressureSuppressionEviction

func NewCPUPressureSuppressionEviction(_ metrics.MetricEmitter, _ *metaserver.MetaServer,
	conf *config.Configuration, state state.State) CPUPressureForceEviction

type CPUPressureLoadEviction

type CPUPressureLoadEviction struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*CPUPressureLoadEviction) GetTopEvictionPods

func (p *CPUPressureLoadEviction) GetTopEvictionPods(_ context.Context,
	request *pluginapi.GetTopEvictionPodsRequest) (*pluginapi.GetTopEvictionPodsResponse, error)

func (*CPUPressureLoadEviction) Name

func (p *CPUPressureLoadEviction) Name() string

func (*CPUPressureLoadEviction) Start

func (p *CPUPressureLoadEviction) Start(ctx context.Context) (err error)

func (*CPUPressureLoadEviction) ThresholdMet

func (p *CPUPressureLoadEviction) ThresholdMet(_ context.Context,
	_ *pluginapi.Empty) (*pluginapi.ThresholdMetResponse, error)

type CPUPressureSuppression

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

func (*CPUPressureSuppression) GetEvictPods

func (p *CPUPressureSuppression) GetEvictPods(_ context.Context, request *pluginapi.GetEvictPodsRequest) (*pluginapi.GetEvictPodsResponse, error)

func (*CPUPressureSuppression) Name

func (p *CPUPressureSuppression) Name() string

func (*CPUPressureSuppression) Start

func (p *CPUPressureSuppression) Start(context.Context) error

type CPUPressureThresholdEviction

type CPUPressureThresholdEviction interface {
	CPUPressureEviction
	ThresholdMet(context.Context, *pluginapi.Empty) (*pluginapi.ThresholdMetResponse, error)
	GetTopEvictionPods(context.Context, *pluginapi.GetTopEvictionPodsRequest) (*pluginapi.GetTopEvictionPodsResponse, error)
}

func NewCPUPressureEviction

func NewCPUPressureEviction(emitter metrics.MetricEmitter, metaServer *metaserver.MetaServer,
	conf *config.Configuration, state state.State) CPUPressureThresholdEviction

type Entries

type Entries map[string]SubEntries

Entries are keyed by pod UID or pool name

type MetricInfo

type MetricInfo struct {
	Name       string
	Value      float64
	UpperBound float64
	LowerBound float64
}

type MetricRing

type MetricRing struct {
	MaxLen       int
	Queue        []*MetricSnapshot
	CurrentIndex int

	sync.RWMutex
}

func CreateMetricRing

func CreateMetricRing(size int) *MetricRing

func (*MetricRing) Count

func (ring *MetricRing) Count() (softOverCount, hardOverCount int)

func (*MetricRing) Push

func (ring *MetricRing) Push(snapShot *MetricSnapshot)

func (*MetricRing) Sum

func (ring *MetricRing) Sum() float64

type MetricSnapshot

type MetricSnapshot struct {
	Info MetricInfo
	Time int64
}

type PoolMetricCollectHandler

type PoolMetricCollectHandler func(metricName string, metricValue float64, _ *state.AllocationInfo, collectTime int64)

type SubEntries

type SubEntries map[string]*MetricRing

SubEntries is keyed by container name or empty string (for pool)

func (SubEntries) IsPoolEntry

func (se SubEntries) IsPoolEntry() bool