controllers

Jan 13, 2024

Changes in this version

type EtcdPlane

+ func (ep *EtcdPlane) OutOfDateMachines() collections.Machines

Sep 7, 2023

Changes in this version

+ type EtcdClient interface

+ Close func() error

+ MemberList func(ctx context.Context) (*clientv3.MemberListResponse, error)

+ MemberRemove func(ctx context.Context, id uint64) (*clientv3.MemberRemoveResponse, error)

type EtcdadmClusterReconciler

+ GetEtcdClient func(ctx context.Context, cluster *clusterv1.Cluster, endpoints string) (EtcdClient, error)

+ HealthCheckInterval time.Duration

+ func (r *EtcdadmClusterReconciler) SetIsPortOpen(s func(ctx context.Context, endpoint string) bool)

Jul 19, 2023

Changes in this version

type EtcdadmClusterReconciler

+ MaxConcurrentReconciles int

Mar 6, 2023

Changes in this version

+ const MachineEtcdReadyLabelName

May 31, 2022

Changes in this version

+ func EtcdClusterMachines(clusterName, etcdClusterName string) func(machine *clusterv1.Machine) bool

+ func EtcdLabelsForCluster(clusterName string, etcdClusterName string) map[string]string

+ func EtcdMachinesSelectorForCluster(clusterName, etcdClusterName string) labels.Selector

+ func MatchesEtcdadmClusterConfiguration(infraConfigs map[string]*unstructured.Unstructured, ...) func(machine *clusterv1.Machine) bool

+ func MatchesEtcdadmConfig(machineConfigs map[string]*etcdbootstrapv1.EtcdadmConfig, ...) collections.Func

+ func MatchesTemplateClonedFrom(infraConfigs map[string]*unstructured.Unstructured, ec *etcdv1.EtcdadmCluster) collections.Func

+ type EtcdPlane struct

+ Cluster *clusterv1.Cluster

+ EC *etcdv1.EtcdadmCluster

+ Machines collections.Machines

+ func NewEtcdPlane(ctx context.Context, client client.Client, cluster *clusterv1.Cluster, ...) (*EtcdPlane, error)

+ func (ep *EtcdPlane) FailureDomainWithMostMachines(machines collections.Machines) *string

+ func (ep *EtcdPlane) FailureDomains() clusterv1.FailureDomains

+ func (ep *EtcdPlane) MachineInFailureDomainWithMostMachines(machines collections.Machines) (*clusterv1.Machine, error)

+ func (ep *EtcdPlane) MachineWithDeleteAnnotation(machines collections.Machines) collections.Machines

+ func (ep *EtcdPlane) MachinesNeedingRollout() collections.Machines

+ func (ep *EtcdPlane) NewestUpToDateMachine() *clusterv1.Machine

+ func (ep *EtcdPlane) NextFailureDomainForScaleUp() *string

+ func (ep *EtcdPlane) UpToDateMachines() collections.Machines

+ type EtcdadmClusterReconciler struct

+ Log logr.Logger

+ Scheme *runtime.Scheme

+ func (r *EtcdadmClusterReconciler) ClusterToEtcdadmCluster(o client.Object) []ctrl.Request

+ func (r *EtcdadmClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (res ctrl.Result, reterr error)

+ func (r *EtcdadmClusterReconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, done <-chan struct{}) error