helper

Documentation

Index

• func ApplyDesiredState(client client.Client, desiredState shared.State) (string, error)
• func CreateOrUpdateNodeNetworkState(client client.Client, node *corev1.Node, namespace client.ObjectKey, ...) error
• func EventIsForThisNode(meta v1.Object) bool
• func GetNodeNetworkState(client client.Client, nodeName string) (nmstatev1beta1.NodeNetworkState, error)
• func InitializeNodeNetworkState(client client.Client, node *corev1.Node) (*nmstatev1beta1.NodeNetworkState, error)
• func UpdateCurrentState(client client.Client, nodeNetworkState *nmstatev1beta1.NodeNetworkState, ...) error

Functions

func ApplyDesiredState

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

func CreateOrUpdateNodeNetworkState

func CreateOrUpdateNodeNetworkState(client client.Client, node *corev1.Node, namespace client.ObjectKey, observedState shared.State) 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 GetNodeNetworkState

func GetNodeNetworkState(client client.Client, nodeName string) (nmstatev1beta1.NodeNetworkState, error)

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