Documentation
¶
Index ¶
- func ApplyKubeletConfigToNode(node *corev1.Node, name string, spec *mcov1.KubeletConfigSpec) (func() error, error)
- func DecodeMCYaml(mcyaml string) (*mcov1.MachineConfig, error)
- func FindMCPByMCLabel(mcLabel string) (mcov1.MachineConfigPool, error)
- func FindNodeSelectorByMCLabel(mcLabel string) (string, error)
- func WaitForAllMCPStable() error
- func WaitForAtLeastOneMCPUpdating() error
- func WaitForCondition(cs *testclient.ClientSet, mcp *mcov1.MachineConfigPool, ...) error
- func WaitForMCPStable(mcp mcov1.MachineConfigPool) error
- func WaitForMCPUpdated(mcp mcov1.MachineConfigPool) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ApplyKubeletConfigToNode ¶
func ApplyKubeletConfigToNode(node *corev1.Node, name string, spec *mcov1.KubeletConfigSpec) (func() error, error)
ApplyKubeletConfigToNode creates a KubeletConfig, a MachineConfigPool and a `node-role.kubernetes.io/<name>` label in order to target a single node in the cluster. The role label is applied to the target node after removing any provious `node-role.kubernetes.io/` label, as MachineConfigOperator doesn't support multiple roles. Return value is a function that can be used to revert the node labeling.
func DecodeMCYaml ¶
func DecodeMCYaml(mcyaml string) (*mcov1.MachineConfig, error)
DecodeMCYaml decodes a MachineConfig YAML to a MachineConfig struct
func FindMCPByMCLabel ¶
func FindMCPByMCLabel(mcLabel string) (mcov1.MachineConfigPool, error)
FindMCPByMCLabel returns the MCP that targets machine configs with mcLabel
func FindNodeSelectorByMCLabel ¶
FindNodeSelectorByMCLabel returns the node selector of the mcp that targets machine configs with mcLabel
func WaitForAllMCPStable ¶
func WaitForAllMCPStable() error
WaitForAllMCPStable waits until all MachineConfigPools in the cluster are not updating (i.e. Updated or Degraded)
func WaitForAtLeastOneMCPUpdating ¶
func WaitForAtLeastOneMCPUpdating() error
WaitForAtLeastOneMCPUpdating waits until at least one MachineConfigPools in the cluster is updating
func WaitForCondition ¶
func WaitForCondition( cs *testclient.ClientSet, mcp *mcov1.MachineConfigPool, conditionType mcov1.MachineConfigPoolConditionType, conditionStatus corev1.ConditionStatus, timeout time.Duration, ) error
WaitForCondition waits until the machine config pool will have specified condition type with the expected status
func WaitForMCPStable ¶
func WaitForMCPStable(mcp mcov1.MachineConfigPool) error
WaitForMCPStable waits until the mcp is updating and then waits for mcp to be stable again. Former wait is useful to avoid returning from this function before the operator is working.
func WaitForMCPUpdated ¶
func WaitForMCPUpdated(mcp mcov1.MachineConfigPool) error
WaitForMCPUpdated waits for the MCP to be in the updated state.
Types ¶
This section is empty.
Source Files