Versions in this module Expand all Collapse all v0 v0.0.3 Oct 18, 2023 Changes in this version + const K3ssControlPlaneControllerName + var Log = klogr.New() + func ControlPlaneMachineLabelsForCluster(kcp *infracontrolplanev1.K3sControlPlane, clusterName string) map[string]string + func MatchesK3sBootstrapConfig(machineConfigs map[string]*infrabootstrapv1.K3sConfig, ...) collections.Func + func MatchesMachineSpec(infraConfigs map[string]*unstructured.Unstructured, ...) func(machine *clusterv1.Machine) bool + func MatchesTemplateClonedFrom(infraConfigs map[string]*unstructured.Unstructured, ...) collections.Func + type ControlPlane struct + Cluster *clusterv1.Cluster + KCP *infracontrolplanev1.K3sControlPlane + Machines collections.Machines + func NewControlPlane(ctx context.Context, client client.Client, cluster *clusterv1.Cluster, ...) (*ControlPlane, error) + func (c *ControlPlane) AsOwnerReference() *metav1.OwnerReference + func (c *ControlPlane) FailureDomainWithMostMachines(machines collections.Machines) *string + func (c *ControlPlane) FailureDomains() clusterv1.FailureDomains + func (c *ControlPlane) GenerateK3sConfig(spec *infrabootstrapv1.K3sConfigSpec) *infrabootstrapv1.K3sConfig + func (c *ControlPlane) HasDeletingMachine() bool + func (c *ControlPlane) InitialControlPlaneConfig() *infrabootstrapv1.K3sConfigSpec + func (c *ControlPlane) JoinControlPlaneConfig() *infrabootstrapv1.K3sConfigSpec + func (c *ControlPlane) Logger() logr.Logger + func (c *ControlPlane) MachineInFailureDomainWithMostMachines(machines collections.Machines) (*clusterv1.Machine, error) + func (c *ControlPlane) MachineInfrastructureTemplateRef() *corev1.ObjectReference + func (c *ControlPlane) MachineWithDeleteAnnotation(machines collections.Machines) collections.Machines + func (c *ControlPlane) MachinesNeedingRollout() collections.Machines + func (c *ControlPlane) NextFailureDomainForScaleUp() *string + func (c *ControlPlane) PatchMachines(ctx context.Context) error + func (c *ControlPlane) UpToDateMachines() collections.Machines + func (c *ControlPlane) Version() *string + type Management struct + Client client.Reader + Tracker *remote.ClusterCacheTracker + func (m *Management) Get(ctx context.Context, key client.ObjectKey, obj client.Object) error + func (m *Management) GetMachinePoolsForCluster(ctx context.Context, cluster *clusterv1.Cluster) (*expv1.MachinePoolList, error) + func (m *Management) GetMachinesForCluster(ctx context.Context, cluster *clusterv1.Cluster, filters ...collections.Func) (collections.Machines, error) + func (m *Management) GetWorkloadCluster(ctx context.Context, clusterKey client.ObjectKey) (WorkloadCluster, error) + func (m *Management) List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error + type ManagementCluster interface + GetMachinePoolsForCluster func(ctx context.Context, cluster *clusterv1.Cluster) (*expv1.MachinePoolList, error) + GetMachinesForCluster func(ctx context.Context, cluster *clusterv1.Cluster, filters ...collections.Func) (collections.Machines, error) + GetWorkloadCluster func(ctx context.Context, clusterKey client.ObjectKey) (WorkloadCluster, error) + type RemoteClusterConnectionError struct + Err error + Name string + func (e *RemoteClusterConnectionError) Error() string + func (e *RemoteClusterConnectionError) Unwrap() error + type Status struct + Nodes int32 + ReadyNodes int32 + type Workload struct + Client ctrlclient.Client + func (w *Workload) ClusterStatus(ctx context.Context) (Status, error) + func (w *Workload) UpdateAgentConditions(ctx context.Context, controlPlane *ControlPlane) + func (w *Workload) UpdateEtcdConditions(ctx context.Context, controlPlane *ControlPlane) + type WorkloadCluster interface + ClusterStatus func(ctx context.Context) (Status, error) + UpdateAgentConditions func(ctx context.Context, controlPlane *ControlPlane) + UpdateEtcdConditions func(ctx context.Context, controlPlane *ControlPlane)