node

Documentation

Index

• Constants
• func EventIsForThisNode(meta v1.Object) bool
• func FilterReady(nodes []corev1.Node) []corev1.Node
• func MaxUnavailableNodeCount(cli client.Reader, policy *nmstatev1.NodeNetworkConfigurationPolicy) (int, error)
• func NetworkStateRefreshWithJitter() time.Duration
• func NodesRunningNmstate(cli client.Reader, nodeSelector map[string]string) ([]corev1.Node, error)
• func ScaledMaxUnavailableNodeCount(matchingNodes int, intOrPercent intstr.IntOrString) (int, error)
• type MaxUnavailableLimitReachedError
  • func (f MaxUnavailableLimitReachedError) Error() string

Constants

const (
	DefaultMaxunavailable = "50%"
	MinMaxunavailable     = 1
)

const (
	NetworkStateRefresh          = time.Minute
	NetworkStateRefreshMaxFactor = 0.1
)

Functions

func EventIsForThisNode

func EventIsForThisNode(meta v1.Object) bool

Return true if the event name is the name of the pods's node (reading the env var NODE_NAME)

func FilterReady

func FilterReady(nodes []corev1.Node) []corev1.Node

func MaxUnavailableNodeCount

func MaxUnavailableNodeCount(cli client.Reader, policy *nmstatev1.NodeNetworkConfigurationPolicy) (int, error)

func NetworkStateRefreshWithJitter

func NetworkStateRefreshWithJitter() time.Duration

NodeNetworkStateRefreshWithJitter add some jitter to to the refresh rate so it does not hit apiserver at the same time.

func NodesRunningNmstate

func NodesRunningNmstate(cli client.Reader, nodeSelector map[string]string) ([]corev1.Node, error)

func ScaledMaxUnavailableNodeCount

func ScaledMaxUnavailableNodeCount(matchingNodes int, intOrPercent intstr.IntOrString) (int, error)

Types

type MaxUnavailableLimitReachedError

type MaxUnavailableLimitReachedError struct{}

func (MaxUnavailableLimitReachedError) Error

func (f MaxUnavailableLimitReachedError) Error() string