helper

Documentation

Index

• Constants
• func ApplyDefaultVlanFiltering(desiredState nmstate.State) (nmstate.State, error)
• func ApplyDesiredState(client client.Client, desiredState shared.State) (string, error)
• func CreateOrUpdateNodeNetworkState(client client.Client, node *corev1.Node, observedState shared.State, ...) error
• func EventIsForThisNode(meta v1.Object) bool
• func InitializeNodeNetworkState(client client.Client, node *corev1.Node) (*nmstatev1beta1.NodeNetworkState, error)
• func UpdateCurrentState(client client.Client, nodeNetworkState *nmstatev1beta1.NodeNetworkState, ...) error

Constants

const (

	// DesiredStateConfigurationTimeout doubles the default gw ping probe and API server
	// connectivity check timeout to ensure the Checkpoint is alive before rolling it back
	// https://nmstate.github.io/cli_guide#manual-transaction-control
	DesiredStateConfigurationTimeout = (defaultGwProbeTimeout + apiServerProbeTimeout) * 2
)

Functions

func ApplyDefaultVlanFiltering

func ApplyDefaultVlanFiltering(desiredState nmstate.State) (nmstate.State, error)

func ApplyDesiredState

func ApplyDesiredState(client client.Client, desiredState shared.State) (string, error)

func CreateOrUpdateNodeNetworkState

func CreateOrUpdateNodeNetworkState(client client.Client, node *corev1.Node, observedState shared.State, nns *nmstatev1beta1.NodeNetworkState) error

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 InitializeNodeNetworkState

func InitializeNodeNetworkState(client client.Client, node *corev1.Node) (*nmstatev1beta1.NodeNetworkState, error)

func UpdateCurrentState

func UpdateCurrentState(client client.Client, nodeNetworkState *nmstatev1beta1.NodeNetworkState, observedState shared.State) error