helper

Documentation

Index

• 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 EnableVlanFiltering(desiredState nmstate.State) (string, error)
• func EventIsForThisNode(meta v1.Object) bool
• func GetUpLinuxBridgesWithPorts(desiredState nmstate.State) (map[string][]string, error)
• func InitializeNodeNetworkState(client client.Client, node *corev1.Node) (*nmstatev1beta1.NodeNetworkState, error)
• func UpdateCurrentState(client client.Client, nodeNetworkState *nmstatev1beta1.NodeNetworkState, ...) error

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 EnableVlanFiltering

func EnableVlanFiltering(desiredState nmstate.State) (string, 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 GetUpLinuxBridgesWithPorts

func GetUpLinuxBridgesWithPorts(desiredState nmstate.State) (map[string][]string, 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