package locking

import "sigs.k8s.io/cluster-api/bootstrap/kubeadm/internal/locking"

Index ¶

• type ControlPlaneInitMutex
• func NewControlPlaneInitMutex(log logr.Logger, client client.Client) *ControlPlaneInitMutex
• func (c *ControlPlaneInitMutex) Lock(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) bool
• func (c *ControlPlaneInitMutex) Unlock(ctx context.Context, cluster *clusterv1.Cluster) bool

Package Files ¶

control_plane_init_mutex.go

type ControlPlaneInitMutex ¶ Uses

type ControlPlaneInitMutex struct {
    // contains filtered or unexported fields
}

ControlPlaneInitMutex uses a ConfigMap to synchronize cluster initialization.

func NewControlPlaneInitMutex ¶ Uses

func NewControlPlaneInitMutex(log logr.Logger, client client.Client) *ControlPlaneInitMutex

NewControlPlaneInitMutex returns a lock that can be held by a control plane node before init.

func (*ControlPlaneInitMutex) Lock ¶ Uses

func (c *ControlPlaneInitMutex) Lock(ctx context.Context, cluster *clusterv1.Cluster, machine *clusterv1.Machine) bool

Lock allows a control plane node to be the first and only node to run kubeadm init

func (*ControlPlaneInitMutex) Unlock ¶ Uses

func (c *ControlPlaneInitMutex) Unlock(ctx context.Context, cluster *clusterv1.Cluster) bool

Unlock releases the lock