machinefilters

Documentation

Index

• func AdoptableControlPlaneMachines(clusterName string) func(machine *clusterv1.Machine) bool
• func ControlPlaneMachines(clusterName string) func(machine *clusterv1.Machine) bool
• func ControlPlaneSelectorForCluster(clusterName string) labels.Selector
• func HasControllerRef(machine *clusterv1.Machine) bool
• func HasDeletionTimestamp(machine *clusterv1.Machine) bool
• func HasUnhealthyCondition(machine *clusterv1.Machine) bool
• func MatchesKCPConfiguration(infraConfigs map[string]*unstructured.Unstructured, ...) func(machine *clusterv1.Machine) bool
• func OwnedMachines(owner controllerutil.Object) func(machine *clusterv1.Machine) bool
• type Func
  • func And(filters ...Func) Func
  • func HasAnnotationKey(key string) Func
  • func InFailureDomains(failureDomains ...*string) Func
  • func IsReady() Func
  • func MatchesKThreesBootstrapConfig(machineConfigs map[string]*bootstrapv1.KThreesConfig, ...) Func
  • func MatchesKubernetesVersion(kubernetesVersion string) Func
  • func MatchesTemplateClonedFrom(infraConfigs map[string]*unstructured.Unstructured, ...) Func
  • func Not(mf Func) Func
  • func Or(filters ...Func) Func
  • func ShouldRolloutAfter(reconciliationTime, rolloutAfter *metav1.Time) Func

Functions

func AdoptableControlPlaneMachines

func AdoptableControlPlaneMachines(clusterName string) func(machine *clusterv1.Machine) bool

AdoptableControlPlaneMachines returns a filter to find all un-controlled control plane machines. Usage: managementCluster.GetMachinesForCluster(ctx, cluster, AdoptableControlPlaneMachines(cluster.Name, controlPlane))

func ControlPlaneMachines

func ControlPlaneMachines(clusterName string) func(machine *clusterv1.Machine) bool

ControlPlaneMachines returns a filter to find all control plane machines for a cluster, regardless of ownership. Usage: managementCluster.GetMachinesForCluster(ctx, cluster, machinefilters.ControlPlaneMachines(cluster.Name))

func ControlPlaneSelectorForCluster

func ControlPlaneSelectorForCluster(clusterName string) labels.Selector

ControlPlaneSelectorForCluster returns the label selector necessary to get control plane machines for a given cluster.

func HasControllerRef

func HasControllerRef(machine *clusterv1.Machine) bool

HasControllerRef is a filter that returns true if the machine has a controller ref

func HasDeletionTimestamp

func HasDeletionTimestamp(machine *clusterv1.Machine) bool

HasDeletionTimestamp returns a filter to find all machines that have a deletion timestamp.

func HasUnhealthyCondition

func HasUnhealthyCondition(machine *clusterv1.Machine) bool

HasUnhealthyCondition returns a filter to find all machines that have a MachineHealthCheckSucceeded condition set to False, indicating a problem was detected on the machine, and the MachineOwnerRemediated condition set, indicating that KCP is responsible of performing remediation as owner of the machine.

func MatchesKCPConfiguration

func MatchesKCPConfiguration(infraConfigs map[string]*unstructured.Unstructured, machineConfigs map[string]*bootstrapv1.KThreesConfig, kcp *controlplanev1.KThreesControlPlane) func(machine *clusterv1.Machine) bool

MatchesKCPConfiguration returns a filter to find all machines that matches with KCP config and do not require any rollout. Kubernetes version, infrastructure template, and KThreesConfig field need to be equivalent.

func OwnedMachines

func OwnedMachines(owner controllerutil.Object) func(machine *clusterv1.Machine) bool

OwnedMachines returns a filter to find all owned control plane machines. Usage: managementCluster.GetMachinesForCluster(ctx, cluster, machinefilters.OwnedMachines(controlPlane))

Types

type Func

type Func func(machine *clusterv1.Machine) bool

func And

func And(filters ...Func) Func

And returns a filter that returns true if all of the given filters returns true.

func HasAnnotationKey

func HasAnnotationKey(key string) Func

HasAnnotationKey returns a filter to find all machines that have the specified Annotation key present

func InFailureDomains

func InFailureDomains(failureDomains ...*string) Func

InFailureDomains returns a filter to find all machines in any of the given failure domains

func IsReady

func IsReady() Func

IsReady returns a filter to find all machines with the ReadyCondition equals to True.

func MatchesKThreesBootstrapConfig

func MatchesKThreesBootstrapConfig(machineConfigs map[string]*bootstrapv1.KThreesConfig, kcp *controlplanev1.KThreesControlPlane) Func

MatchesKThreesBootstrapConfig checks if machine's KThreesConfigSpec is equivalent with KCP's KThreesConfigSpec.

func MatchesKubernetesVersion

func MatchesKubernetesVersion(kubernetesVersion string) Func

MatchesKubernetesVersion returns a filter to find all machines that match a given Kubernetes version.

func MatchesTemplateClonedFrom

func MatchesTemplateClonedFrom(infraConfigs map[string]*unstructured.Unstructured, kcp *controlplanev1.KThreesControlPlane) Func

MatchesTemplateClonedFrom returns a filter to find all machines that match a given KCP infra template.

func Not

func Not(mf Func) Func

Not returns a filter that returns the opposite of the given filter.

func Or

func Or(filters ...Func) Func

Or returns a filter that returns true if any of the given filters returns true.

func ShouldRolloutAfter

func ShouldRolloutAfter(reconciliationTime, rolloutAfter *metav1.Time) Func

ShouldRolloutAfter returns a filter to find all machines where CreationTimestamp < rolloutAfter < reconciliationTIme