lock

Documentation

Index

• Constants
• Variables
• func AcquireLock(cli kubeclientset.Interface) error
• func DeleteLock(cli kubeclientset.Interface) error
• func ReleaseLock(cli kubeclientset.Interface) error

Constants

const (
	AnnotationAcquireTime = "openyurt.io/yurtctllock.acquire.time"
	AnnotationIsLocked    = "openyurt.io/yurtctllock.locked"

	LockTimeoutMin = 5
)

Variables

var (
	ErrAcquireLock error = errors.New("fail to acquire lock configmap/yurtctl-lock")
	ErrReleaseLock error = errors.New("fail to release lock configmap/yurtctl-lock")
)

Functions

func AcquireLock

func AcquireLock(cli kubeclientset.Interface) error

AcquireLock tries to acquire the lock lock configmap/yurtctl-lock

func DeleteLock

func DeleteLock(cli kubeclientset.Interface) error

DeleteLock should only be called when you've achieved the lock. It will delete the yurtctl-lock configmap.

func ReleaseLock

func ReleaseLock(cli kubeclientset.Interface) error

ReleaseLock releases the lock configmap/yurtctl-lock