Versions in this module Expand all Collapse all v0 v0.0.3 Oct 18, 2023 Changes in this version + var ErrNodeNotFound = errors.New("cannot find node with matching ProviderID") + type Locker interface + Lock func(ctx context.Context, cluster *clusterv1.Cluster, ...) bool + Unlock func(ctx context.Context, cluster *clusterv1.Cluster) bool + type Mutex struct + func NewMutex(client client.Client) *Mutex + func (m *Mutex) Lock(ctx context.Context, cluster *clusterv1.Cluster, ...) bool + func (m *Mutex) Unlock(ctx context.Context, cluster *clusterv1.Cluster) bool + type Reconciler struct + DataDir string + Lock Locker + Recorder record.EventRecorder + Scheme *runtime.Scheme + Tracker *remote.ClusterCacheTracker + WaitKKInstanceInterval time.Duration + WaitKKInstanceTimeout time.Duration + WatchFilterValue string + func (r *Reconciler) KKClusterToKKInstances(log logr.Logger) handler.MapFunc + func (r *Reconciler) KKMachineToKKInstanceMapFunc(log logr.Logger) handler.MapFunc + func (r *Reconciler) Reconcile(ctx context.Context, req ctrl.Request) (_ ctrl.Result, retErr error) + func (r *Reconciler) SetupWithManager(ctx context.Context, mgr ctrl.Manager, options controller.Options) error