state

Documentation

Index

• type Cluster
  • func NewCluster(clk clock.Clock, client client.Client, cp cloudprovider.CloudProvider) *Cluster
  • func (c *Cluster) ClusterConsolidationState() int64
  • func (c *Cluster) DeleteNode(nodeName string)
  • func (c *Cluster) DeletePod(podKey types.NamespacedName)
  • func (c *Cluster) ForEachNode(f func(n *Node) bool)
  • func (c *Cluster) ForPodsWithAntiAffinity(fn func(p *v1.Pod, n *v1.Node) bool)
  • func (c *Cluster) IsNodeNominated(name string) bool
  • func (c *Cluster) MarkForDeletion(names ...string)
  • func (c *Cluster) NominateNodeForPod(ctx context.Context, name string)
  • func (c *Cluster) RecordConsolidationChange()
  • func (c *Cluster) Reset()
  • func (c *Cluster) UnmarkForDeletion(names ...string)
  • func (c *Cluster) UpdateNode(ctx context.Context, node *v1.Node) error
  • func (c *Cluster) UpdatePod(ctx context.Context, pod *v1.Pod) error
• type Node
  • func (in *Node) Allocatable() v1.ResourceList
  • func (in *Node) Available() v1.ResourceList
  • func (in *Node) Capacity() v1.ResourceList
  • func (in *Node) DaemonSetLimits() v1.ResourceList
  • func (in *Node) DaemonSetRequests() v1.ResourceList
  • func (in *Node) DeepCopy() *Node
  • func (in *Node) DeepCopyInto(out *Node)
  • func (in *Node) HostPortUsage() *scheduling.HostPortUsage
  • func (in *Node) Initialized() bool
  • func (in *Node) MarkedForDeletion() bool
  • func (in *Node) Nominate(ctx context.Context)
  • func (in *Node) Nominated() bool
  • func (in *Node) Owned() bool
  • func (in *Node) PodLimits() v1.ResourceList
  • func (in *Node) PodRequests() v1.ResourceList
  • func (in *Node) Taints() []v1.Taint
  • func (in *Node) VolumeLimits() scheduling.VolumeCount
  • func (in *Node) VolumeUsage() *scheduling.VolumeUsage

Types

type Cluster

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

Cluster maintains cluster state that is often needed but expensive to compute.

func NewCluster

func NewCluster(clk clock.Clock, client client.Client, cp cloudprovider.CloudProvider) *Cluster

func (*Cluster) ClusterConsolidationState

func (c *Cluster) ClusterConsolidationState() int64

ClusterConsolidationState returns a number representing the state of the cluster with respect to consolidation. If consolidation can't occur and this number hasn't changed, there is no point in re-attempting consolidation. This allows reducing overall CPU utilization by pausing consolidation when the cluster is in a static state.

func (*Cluster) DeleteNode

func (c *Cluster) DeleteNode(nodeName string)

func (*Cluster) DeletePod

func (c *Cluster) DeletePod(podKey types.NamespacedName)

DeletePod is called when the pod has been deleted

func (*Cluster) ForEachNode

func (c *Cluster) ForEachNode(f func(n *Node) bool)

ForEachNode calls the supplied function once per node object that is being tracked. It is not safe to store the state.Node object, it should be only accessed from within the function provided to this method.

func (*Cluster) ForPodsWithAntiAffinity

func (c *Cluster) ForPodsWithAntiAffinity(fn func(p *v1.Pod, n *v1.Node) bool)

ForPodsWithAntiAffinity calls the supplied function once for each pod with required anti affinity terms that is currently bound to a node. The pod returned may not be up-to-date with respect to status, however since the anti-affinity terms can't be modified, they will be correct.

func (*Cluster) IsNodeNominated

func (c *Cluster) IsNodeNominated(name string) bool

IsNodeNominated returns true if the given node was expected to have a pod bound to it during a recent scheduling batch

func (*Cluster) MarkForDeletion

func (c *Cluster) MarkForDeletion(names ...string)

MarkForDeletion marks the node as pending deletion in the internal cluster state

func (*Cluster) NominateNodeForPod

func (c *Cluster) NominateNodeForPod(ctx context.Context, name string)

NominateNodeForPod records that a node was the target of a pending pod during a scheduling batch

func (*Cluster) RecordConsolidationChange

func (c *Cluster) RecordConsolidationChange()

func (*Cluster) Reset

func (c *Cluster) Reset()

Reset the cluster state for unit testing

func (*Cluster) UnmarkForDeletion

func (c *Cluster) UnmarkForDeletion(names ...string)

UnmarkForDeletion removes the marking on the node as a node the controller intends to delete

func (*Cluster) UpdateNode

func (c *Cluster) UpdateNode(ctx context.Context, node *v1.Node) error

UpdateNode is called for every node reconciliation

func (*Cluster) UpdatePod

func (c *Cluster) UpdatePod(ctx context.Context, pod *v1.Pod) error

UpdatePod is called every time the pod is reconciled

type Node

type Node struct {
	Node *v1.Node
	// contains filtered or unexported fields
}

Node is a cached version of a node in the cluster that maintains state which is expensive to compute every time it's needed. This currently contains node utilization across all the allocatable resources, but will soon be used to compute topology information. +k8s:deepcopy-gen=true

func (*Node) Allocatable

func (in *Node) Allocatable() v1.ResourceList

func (*Node) Available

func (in *Node) Available() v1.ResourceList

Available is allocatable minus anything allocated to pods.

func (*Node) Capacity

func (in *Node) Capacity() v1.ResourceList

func (*Node) DaemonSetLimits

func (in *Node) DaemonSetLimits() v1.ResourceList

func (*Node) DaemonSetRequests

func (in *Node) DaemonSetRequests() v1.ResourceList

func (*Node) DeepCopy

func (in *Node) DeepCopy() *Node

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Node.

func (*Node) DeepCopyInto

func (in *Node) DeepCopyInto(out *Node)

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Node) HostPortUsage

func (in *Node) HostPortUsage() *scheduling.HostPortUsage

func (*Node) Initialized

func (in *Node) Initialized() bool

func (*Node) MarkedForDeletion

func (in *Node) MarkedForDeletion() bool

func (*Node) Nominate

func (in *Node) Nominate(ctx context.Context)

func (*Node) Nominated

func (in *Node) Nominated() bool

func (*Node) Owned

func (in *Node) Owned() bool

func (*Node) PodLimits

func (in *Node) PodLimits() v1.ResourceList

func (*Node) PodRequests

func (in *Node) PodRequests() v1.ResourceList

func (*Node) Taints

func (in *Node) Taints() []v1.Taint

func (*Node) VolumeLimits

func (in *Node) VolumeLimits() scheduling.VolumeCount

func (*Node) VolumeUsage

func (in *Node) VolumeUsage() *scheduling.VolumeUsage