Versions in this module Expand all Collapse all v0 v0.0.3 Oct 18, 2023 Changes in this version + func AddDeploymentToWorkloadCluster(ctx context.Context, input AddDeploymentToWorkloadClusterInput) + func AddPodDisruptionBudget(ctx context.Context, input AddPodDisruptionBudgetInput) + func AddPodDisruptionBudgetV1Beta1(ctx context.Context, input AddPodDisruptionBudgetInputV1Beta1) + func AssertControlPlaneFailureDomains(ctx context.Context, input AssertControlPlaneFailureDomainsInput) + func AssertMachineDeploymentFailureDomains(ctx context.Context, input AssertMachineDeploymentFailureDomainsInput) + func CreateCluster(ctx context.Context, input CreateClusterInput, intervals ...interface{}) + func CreateK3sControlPlane(ctx context.Context, input CreateK3sControlPlaneInput, ...) + func CreateMachineDeployment(ctx context.Context, input CreateMachineDeploymentInput) + func CreateNamespace(ctx context.Context, input CreateNamespaceInput, intervals ...interface{}) *corev1.Namespace + func CreateNamespaceAndWatchEvents(ctx context.Context, input CreateNamespaceAndWatchEventsInput) (*corev1.Namespace, context.CancelFunc) + func CreateRelatedResources(ctx context.Context, input CreateRelatedResourcesInput, ...) + func DeleteAllClustersAndWait(ctx context.Context, input DeleteAllClustersAndWaitInput, ...) + func DeleteCluster(ctx context.Context, input DeleteClusterInput) + func DeleteClusterAndWait(ctx context.Context, input DeleteClusterAndWaitInput, intervals ...interface{}) + func DeleteNamespace(ctx context.Context, input DeleteNamespaceInput, intervals ...interface{}) + func DeployUnevictablePod(ctx context.Context, input DeployUnevictablePodInput) + func DescribeFailedDeployment(input WaitForDeploymentsAvailableInput, deployment *appsv1.Deployment) string + func DiscoverMachineHealthChecksAndWaitForRemediation(ctx context.Context, ...) + func DiscoveryAndWaitForCluster(ctx context.Context, input DiscoveryAndWaitForClusterInput, ...) *clusterv1.Cluster + func DiscoveryAndWaitForControlPlaneInitialized(ctx context.Context, input DiscoveryAndWaitForControlPlaneInitializedInput, ...) *infracontrolplanev1.K3sControlPlane + func DiscoveryAndWaitForMachineDeployments(ctx context.Context, input DiscoveryAndWaitForMachineDeploymentsInput, ...) []*clusterv1.MachineDeployment + func DiscoveryAndWaitForMachinePools(ctx context.Context, input DiscoveryAndWaitForMachinePoolsInput, ...) []*expv1.MachinePool + func DumpAllResources(ctx context.Context, input DumpAllResourcesInput) + func EnsureNamespace(ctx context.Context, mgmt client.Client, namespace string) + func GetAllClustersByNamespace(ctx context.Context, input GetAllClustersByNamespaceInput) []*clusterv1.Cluster + func GetCAPIResources(ctx context.Context, input GetCAPIResourcesInput) []*unstructured.Unstructured + func GetClusterByName(ctx context.Context, input GetClusterByNameInput) *clusterv1.Cluster + func GetClusterClassByName(ctx context.Context, input GetClusterClassByNameInput) *clusterv1.ClusterClass + func GetControlPlaneMachinesByCluster(ctx context.Context, input GetControlPlaneMachinesByClusterInput) []clusterv1.Machine + func GetControllerDeployments(ctx context.Context, input GetControllerDeploymentsInput) []*appsv1.Deployment + func GetK3sControlPlaneByCluster(ctx context.Context, input GetK3sControlPlaneByClusterInput) *infracontrolplanev1.K3sControlPlane + func GetMachineDeploymentsByCluster(ctx context.Context, input GetMachineDeploymentsByClusterInput) []*clusterv1.MachineDeployment + func GetMachineHealthChecksForCluster(ctx context.Context, input GetMachineHealthChecksForClusterInput) []*clusterv1.MachineHealthCheck + func GetMachinePoolsByCluster(ctx context.Context, input GetMachinePoolsByClusterInput) []*expv1.MachinePool + func GetMachinesByMachineDeployments(ctx context.Context, input GetMachinesByMachineDeploymentsInput) []clusterv1.Machine + func GetMachinesByMachineHealthCheck(ctx context.Context, input GetMachinesByMachineHealthCheckInput) []clusterv1.Machine + func ObjectToKind(i runtime.Object) string + func PatchClusterLabel(ctx context.Context, input PatchClusterLabelInput) + func PatchNodeCondition(ctx context.Context, input PatchNodeConditionInput) + func PrettyPrint(v interface{}) string + func ScaleAndWaitControlPlane(ctx context.Context, input ScaleAndWaitControlPlaneInput) + func ScaleAndWaitMachineDeployment(ctx context.Context, input ScaleAndWaitMachineDeploymentInput) + func ScaleAndWaitMachineDeploymentTopology(ctx context.Context, input ScaleAndWaitMachineDeploymentTopologyInput) + func ScaleMachinePoolAndWait(ctx context.Context, input ScaleMachinePoolAndWaitInput) + func TryAddDefaultSchemes(scheme *runtime.Scheme) + func UpgradeClusterTopologyAndWaitForUpgrade(ctx context.Context, input UpgradeClusterTopologyAndWaitForUpgradeInput) + func UpgradeControlPlaneAndWaitForUpgrade(ctx context.Context, input UpgradeControlPlaneAndWaitForUpgradeInput) + func UpgradeMachineDeploymentInfrastructureRefAndWait(ctx context.Context, ...) + func UpgradeMachineDeploymentsAndWait(ctx context.Context, input UpgradeMachineDeploymentsAndWaitInput) + func UpgradeMachinePoolAndWait(ctx context.Context, input UpgradeMachinePoolAndWaitInput) + func WaitForClusterDeleted(ctx context.Context, input WaitForClusterDeletedInput, ...) + func WaitForClusterToProvision(ctx context.Context, input WaitForClusterToProvisionInput, ...) *clusterv1.Cluster + func WaitForControlPlaneAndMachinesReady(ctx context.Context, input WaitForControlPlaneAndMachinesReadyInput, ...) + func WaitForControlPlaneMachinesToBeUpgraded(ctx context.Context, input WaitForControlPlaneMachinesToBeUpgradedInput, ...) + func WaitForControlPlaneToBeReady(ctx context.Context, input WaitForControlPlaneToBeReadyInput, ...) + func WaitForDNSUpgrade(ctx context.Context, input WaitForDNSUpgradeInput, intervals ...interface{}) + func WaitForDeploymentsAvailable(ctx context.Context, input WaitForDeploymentsAvailableInput, ...) + func WaitForK3sControlPlaneMachinesToExist(ctx context.Context, input WaitForK3sControlPlaneMachinesToExistInput, ...) + func WaitForKubeProxyUpgrade(ctx context.Context, input WaitForKubeProxyUpgradeInput, ...) + func WaitForMachineDeploymentMachinesToBeUpgraded(ctx context.Context, input WaitForMachineDeploymentMachinesToBeUpgradedInput, ...) + func WaitForMachineDeploymentNodesToExist(ctx context.Context, input WaitForMachineDeploymentNodesToExistInput, ...) + func WaitForMachineDeploymentRollingUpgradeToComplete(ctx context.Context, ...) + func WaitForMachineDeploymentRollingUpgradeToStart(ctx context.Context, input WaitForMachineDeploymentRollingUpgradeToStartInput, ...) + func WaitForMachineHealthCheckToRemediateUnhealthyNodeCondition(ctx context.Context, ...) + func WaitForMachinePoolInstancesToBeUpgraded(ctx context.Context, input WaitForMachinePoolInstancesToBeUpgradedInput, ...) + func WaitForMachinePoolNodesToExist(ctx context.Context, input WaitForMachinePoolNodesToExistInput, ...) + func WaitForMachineStatusCheck(ctx context.Context, input WaitForMachineStatusCheckInput, ...) + func WaitForOneK3sControlPlaneMachineToExist(ctx context.Context, input WaitForOneK3sControlPlaneMachineToExistInput, ...) + func WaitForPodListCondition(ctx context.Context, input WaitForPodListConditionInput, ...) + func WatchDeploymentLogs(ctx context.Context, input WatchDeploymentLogsInput) + func WatchNamespaceEvents(ctx context.Context, input WatchNamespaceEventsInput) + func WatchPodMetrics(ctx context.Context, input WatchPodMetricsInput) + type AddDeploymentToWorkloadClusterInput struct + ClientSet *kubernetes.Clientset + Deployment *appsv1.Deployment + Namespace string + type AddPodDisruptionBudgetInput struct + Budget *policyv1.PodDisruptionBudget + ClientSet *kubernetes.Clientset + Namespace string + type AddPodDisruptionBudgetInputV1Beta1 struct + Budget *v1beta1.PodDisruptionBudget + ClientSet *kubernetes.Clientset + Namespace string + type AssertControlPlaneFailureDomainsInput struct + Cluster *clusterv1.Cluster + Lister Lister + type AssertMachineDeploymentFailureDomainsInput struct + Cluster *clusterv1.Cluster + Lister Lister + MachineDeployment *clusterv1.MachineDeployment + type ClusterLogCollector interface + CollectMachineLog func(ctx context.Context, managementClusterClient client.Client, ...) error + CollectMachinePoolLog func(ctx context.Context, managementClusterClient client.Client, ...) error + type ClusterProxy interface + Apply func(ctx context.Context, resources []byte, args ...string) error + CollectWorkloadClusterLogs func(ctx context.Context, namespace, name, outputPath string) + Dispose func(context.Context) + GetClient func() client.Client + GetClientSet func() *kubernetes.Clientset + GetKubeconfigPath func() string + GetLogCollector func() ClusterLogCollector + GetName func() string + GetRESTConfig func() *rest.Config + GetScheme func() *runtime.Scheme + GetWorkloadCluster func(ctx context.Context, namespace, name string) ClusterProxy + func NewClusterProxy(name string, kubeconfigPath string, scheme *runtime.Scheme, options ...Option) ClusterProxy + type CreateClusterInput struct + Cluster *clusterv1.Cluster + Creator Creator + InfraCluster client.Object + type CreateK3sControlPlaneInput struct + ControlPlane *infracontrolplanev1.K3sControlPlane + Creator Creator + MachineTemplate client.Object + type CreateMachineDeploymentInput struct + BootstrapConfigTemplate client.Object + Creator Creator + InfraMachineTemplate client.Object + MachineDeployment *clusterv1.MachineDeployment + type CreateNamespaceAndWatchEventsInput struct + ClientSet *kubernetes.Clientset + Creator Creator + LogFolder string + Name string + type CreateNamespaceInput struct + Creator Creator + Name string + type CreateRelatedResourcesInput struct + Creator Creator + RelatedResources []client.Object + type Creator interface + Create func(ctx context.Context, obj client.Object, opts ...client.CreateOption) error + type DeleteAllClustersAndWaitInput struct + Client client.Client + Namespace string + type DeleteClusterAndWaitInput struct + Client client.Client + Cluster *clusterv1.Cluster + type DeleteClusterInput struct + Cluster *clusterv1.Cluster + Deleter Deleter + type DeleteNamespaceInput struct + Deleter Deleter + Name string + type Deleter interface + Delete func(ctx context.Context, obj client.Object, opts ...client.DeleteOption) error + type DeployUnevictablePodInput struct + ControlPlane *infracontrolplanev1.K3sControlPlane + DeploymentName string + Namespace string + WaitForDeploymentAvailableInterval []interface{} + WorkloadClusterProxy ClusterProxy + type DiscoverMachineHealthCheckAndWaitForRemediationInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + WaitForMachineRemediation []interface{} + type DiscoveryAndWaitForClusterInput struct + Getter Getter + Name string + Namespace string + type DiscoveryAndWaitForControlPlaneInitializedInput struct + Cluster *clusterv1.Cluster + Lister Lister + type DiscoveryAndWaitForMachineDeploymentsInput struct + Cluster *clusterv1.Cluster + Lister Lister + type DiscoveryAndWaitForMachinePoolsInput struct + Cluster *clusterv1.Cluster + Getter Getter + Lister Lister + type DumpAllResourcesInput struct + Lister Lister + LogPath string + Namespace string + type GetAllClustersByNamespaceInput struct + Lister Lister + Namespace string + type GetCAPIResourcesInput struct + Lister Lister + Namespace string + type GetClusterByNameInput struct + Getter Getter + Name string + Namespace string + type GetClusterClassByNameInput struct + Getter Getter + Name string + Namespace string + type GetControlPlaneMachinesByClusterInput struct + ClusterName string + Lister Lister + Namespace string + type GetControllerDeploymentsInput struct + ExcludeNamespaces []string + Lister Lister + type GetK3sControlPlaneByClusterInput struct + ClusterName string + Lister Lister + Namespace string + type GetLister interface + type GetMachineDeploymentsByClusterInput struct + ClusterName string + Lister Lister + Namespace string + type GetMachineHealthChecksForClusterInput struct + ClusterName string + Lister Lister + Namespace string + type GetMachinePoolsByClusterInput struct + ClusterName string + Lister Lister + Namespace string + type GetMachinesByMachineDeploymentsInput struct + ClusterName string + Lister Lister + MachineDeployment clusterv1.MachineDeployment + Namespace string + type GetMachinesByMachineHealthCheckInput struct + ClusterName string + Lister Lister + MachineHealthCheck *clusterv1.MachineHealthCheck + type GetMachinesPoolInstancesInput struct + MachinePool *expv1.MachinePool + Namespace string + WorkloadClusterGetter Getter + type Getter interface + Get func(ctx context.Context, key client.ObjectKey, obj client.Object) error + type Lister interface + List func(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error + type MachineStatusCheck func(p *clusterv1.Machine) error + func MachineNodeRefCheck() MachineStatusCheck + func MachinePhaseCheck(expectedPhase string) MachineStatusCheck + type Option func(*clusterProxy) + func WithMachineLogCollector(logCollector ClusterLogCollector) Option + type PatchClusterLabelInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + Labels map[string]string + type PatchNodeConditionInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + Machine clusterv1.Machine + NodeCondition corev1.NodeCondition + type PodListCondition func(p *corev1.PodList) error + func EtcdImageTagCondition(expectedTag string, expectedCount int) PodListCondition + func PhasePodCondition(expectedPhase corev1.PodPhase) PodListCondition + type ScaleAndWaitControlPlaneInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + ControlPlane *infracontrolplanev1.K3sControlPlane + Replicas int32 + WaitForControlPlane []interface{} + type ScaleAndWaitMachineDeploymentInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + MachineDeployment *clusterv1.MachineDeployment + Replicas int32 + WaitForMachineDeployments []interface{} + type ScaleAndWaitMachineDeploymentTopologyInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + Replicas int32 + WaitForMachineDeployments []interface{} + type ScaleMachinePoolAndWaitInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + MachinePools []*expv1.MachinePool + Replicas int32 + WaitForMachinePoolToScale []interface{} + type UpgradeClusterTopologyAndWaitForUpgradeInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + ControlPlane *infracontrolplanev1.K3sControlPlane + DNSImageTag string + EtcdImageTag string + KubernetesUpgradeVersion string + MachineDeployments []*clusterv1.MachineDeployment + PreWaitForControlPlaneToBeUpgraded func() + PreWaitForMachineDeploymentToBeUpgraded func() + WaitForDNSUpgrade []interface{} + WaitForEtcdUpgrade []interface{} + WaitForKubeProxyUpgrade []interface{} + WaitForMachinesToBeUpgraded []interface{} + type UpgradeControlPlaneAndWaitForUpgradeInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + ControlPlane *infracontrolplanev1.K3sControlPlane + DNSImageTag string + EtcdImageTag string + KubernetesUpgradeVersion string + UpgradeMachineTemplate *string + WaitForDNSUpgrade []interface{} + WaitForEtcdUpgrade []interface{} + WaitForKubeProxyUpgrade []interface{} + WaitForMachinesToBeUpgraded []interface{} + type UpgradeMachineDeploymentInfrastructureRefAndWaitInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + MachineDeployments []*clusterv1.MachineDeployment + WaitForMachinesToBeUpgraded []interface{} + type UpgradeMachineDeploymentsAndWaitInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + MachineDeployments []*clusterv1.MachineDeployment + UpgradeMachineTemplate *string + UpgradeVersion string + WaitForMachinesToBeUpgraded []interface{} + type UpgradeMachinePoolAndWaitInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + MachinePools []*expv1.MachinePool + UpgradeVersion string + WaitForMachinePoolToBeUpgraded []interface{} + type WaitForClusterDeletedInput struct + Cluster *clusterv1.Cluster + Getter Getter + type WaitForClusterToProvisionInput struct + Cluster *clusterv1.Cluster + Getter Getter + type WaitForControlPlaneAndMachinesReadyInput struct + Cluster *clusterv1.Cluster + ControlPlane *infracontrolplanev1.K3sControlPlane + GetLister GetLister + type WaitForControlPlaneMachinesToBeUpgradedInput struct + Cluster *clusterv1.Cluster + KubernetesUpgradeVersion string + Lister Lister + MachineCount int + type WaitForControlPlaneToBeReadyInput struct + ControlPlane *infracontrolplanev1.K3sControlPlane + Getter Getter + type WaitForDNSUpgradeInput struct + DNSVersion string + Getter Getter + type WaitForDeploymentsAvailableInput struct + Deployment *appsv1.Deployment + Getter Getter + type WaitForK3sControlPlaneMachinesToExistInput struct + Cluster *clusterv1.Cluster + ControlPlane *infracontrolplanev1.K3sControlPlane + Lister Lister + type WaitForKubeProxyUpgradeInput struct + Getter Getter + KubernetesVersion string + type WaitForMachineDeploymentMachinesToBeUpgradedInput struct + Cluster *clusterv1.Cluster + KubernetesUpgradeVersion string + Lister Lister + MachineCount int + MachineDeployment clusterv1.MachineDeployment + type WaitForMachineDeploymentNodesToExistInput struct + Cluster *clusterv1.Cluster + Lister Lister + MachineDeployment *clusterv1.MachineDeployment + type WaitForMachineDeploymentRollingUpgradeToCompleteInput struct + Getter Getter + MachineDeployment *clusterv1.MachineDeployment + type WaitForMachineDeploymentRollingUpgradeToStartInput struct + Getter Getter + MachineDeployment *clusterv1.MachineDeployment + type WaitForMachineHealthCheckToRemediateUnhealthyNodeConditionInput struct + Cluster *clusterv1.Cluster + ClusterProxy ClusterProxy + MachineHealthCheck *clusterv1.MachineHealthCheck + MachinesCount int + type WaitForMachinePoolInstancesToBeUpgradedInput struct + Cluster *clusterv1.Cluster + Getter Getter + KubernetesUpgradeVersion string + MachineCount int + MachinePool *expv1.MachinePool + WorkloadClusterGetter Getter + type WaitForMachinePoolNodesToExistInput struct + Getter Getter + MachinePool *expv1.MachinePool + type WaitForMachineStatusCheckInput struct + Getter Getter + Machine *clusterv1.Machine + StatusChecks []MachineStatusCheck + type WaitForOneK3sControlPlaneMachineToExistInput struct + Cluster *clusterv1.Cluster + ControlPlane *infracontrolplanev1.K3sControlPlane + Lister Lister + type WaitForPodListConditionInput struct + Condition PodListCondition + ListOptions *client.ListOptions + Lister Lister + type WatchDeploymentLogsInput struct + ClientSet *kubernetes.Clientset + Deployment *appsv1.Deployment + GetLister GetLister + LogPath string + type WatchNamespaceEventsInput struct + ClientSet *kubernetes.Clientset + LogFolder string + Name string + type WatchPodMetricsInput struct + ClientSet *kubernetes.Clientset + Deployment *appsv1.Deployment + GetLister GetLister + MetricsPath string