locking

Documentation

Index

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

Types

type EtcdadmInitMutex

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

EtcdadmInitMutex uses a ConfigMap to synchronize cluster initialization.

func NewEtcdadmInitMutex

func NewEtcdadmInitMutex(log logr.Logger, client client.Client) *EtcdadmInitMutex

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

func (*EtcdadmInitMutex) Lock

func (c *EtcdadmInitMutex) 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 (*EtcdadmInitMutex) Unlock

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

Unlock releases the lock