helper

Documentation

Index

• Constants
• func ApplyDefaultVlanFiltering(desiredState nmstate.State) (nmstate.State, error)
• func ApplyDesiredState(cli client.Client, desiredState shared.State) (string, error)
• func CreateOrUpdateNodeNetworkState(cli client.Client, node *corev1.Node, observedState shared.State, ...) error
• func EnableVlanFiltering(desiredState nmstate.State) (string, error)
• func EventIsForThisNode(meta v1.Object) bool
• func ExecuteCommand(command string, arguments ...string) (string, error)
• func GetUpLinuxBridgesWithPorts(desiredState nmstate.State) (map[string][]string, error)
• func InitializeNodeNetworkState(cli client.Client, node *corev1.Node) (*nmstatev1beta1.NodeNetworkState, error)
• func UpdateCurrentState(cli client.Client, nodeNetworkState *nmstatev1beta1.NodeNetworkState, ...) error
• type DependencyVersions

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(cli client.Client, desiredState shared.State) (string, error)

func CreateOrUpdateNodeNetworkState

func CreateOrUpdateNodeNetworkState(
	cli client.Client,
	node *corev1.Node,
	observedState shared.State,
	nns *nmstatev1beta1.NodeNetworkState,
	versions *DependencyVersions,
) 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 ExecuteCommand

func ExecuteCommand(command string, arguments ...string) (string, error)

func GetUpLinuxBridgesWithPorts

func GetUpLinuxBridgesWithPorts(desiredState nmstate.State) (map[string][]string, error)

func InitializeNodeNetworkState

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

func UpdateCurrentState

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

Types

type DependencyVersions

type DependencyVersions struct {
	HandlerNetworkManagerVersion string
	HandlerNmstateVersion        string
	HostNmstateVersion           string
}