resource

package

v0.0.0-...-3fd892a Latest Latest Go to latest Published: Apr 30, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/kubernetes/autoscaler

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type Delta
type Limits
type LimitsCheckResult
- func CheckDeltaWithinLimits(left Limits, delta Delta) LimitsCheckResult
- func LimitsNotExceeded() LimitsCheckResult
type Manager
- func NewManager(crp customresources.CustomResourcesProcessor) *Manager

Constants ¶

View Source

const LimitUnknown = math.MaxInt64

LimitUnknown is used as a value in ResourcesLimits if actual limit could not be obtained due to errors talking to cloud provider.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Delta ¶

type Delta map[string]int64

Delta is a map: the key is resource type and the value is resource delta.

type Limits ¶

type Limits map[string]int64

Limits is a map: the key is resource type and the value is resource limit.

type LimitsCheckResult ¶

type LimitsCheckResult struct {
	Exceeded          bool
	ExceededResources []string
}

LimitsCheckResult contains the limit check result and the exceeded resources if any.

func CheckDeltaWithinLimits ¶

func CheckDeltaWithinLimits(left Limits, delta Delta) LimitsCheckResult

CheckDeltaWithinLimits compares the resource limit and resource delta, and returns the limit check result.

func LimitsNotExceeded ¶

func LimitsNotExceeded() LimitsCheckResult

LimitsNotExceeded returns a not exceeded limit check result.

type Manager ¶

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

Manager provides resource checks before scaling up the cluster.

func NewManager ¶

func NewManager(crp customresources.CustomResourcesProcessor) *Manager

NewManager creates an instance of scale up resource manager with provided parameters.

func (*Manager) ApplyLimits ¶

func (m *Manager) ApplyLimits(ctx *context.AutoscalingContext, newCount int, resourceLeft Limits, nodeInfo *schedulerframework.NodeInfo, nodeGroup cloudprovider.NodeGroup) (int, errors.AutoscalerError)

ApplyLimits calculates the new node count by applying the left resource limits of the cluster.

func (*Manager) DeltaForNode ¶

func (m *Manager) DeltaForNode(ctx *context.AutoscalingContext, nodeInfo *schedulerframework.NodeInfo, nodeGroup cloudprovider.NodeGroup) (Delta, errors.AutoscalerError)

DeltaForNode calculates the amount of resources that will be used from the cluster when creating a node.

func (*Manager) ResourcesLeft ¶

func (m *Manager) ResourcesLeft(ctx *context.AutoscalingContext, nodeInfos map[string]*schedulerframework.NodeInfo, nodes []*corev1.Node) (Limits, errors.AutoscalerError)

ResourcesLeft calculates the amount of resources left in the cluster.

Source Files ¶

View all Source files

manager.go

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