lock_manager

Sep 15, 2022

Changes in this version

+ type ConfigMapLocker struct

+ ConfigMapName string

+ Locker lockgate.Locker

+ Namespace string

+ func NewConfigMapLocker(configMapName, namespace string, locker lockgate.Locker) *ConfigMapLocker

+ func (locker *ConfigMapLocker) Acquire(lockName string, opts lockgate.AcquireOptions) (bool, lockgate.LockHandle, error)

+ func (locker *ConfigMapLocker) Release(lock lockgate.LockHandle) error

Nov 5, 2020

Changes in this version

+ type LockManager struct

+ LockerWithRetry *locker_with_retry.LockerWithRetry

+ Namespace string

+ func NewLockManager(namespace string) (*LockManager, error)

+ func (lockManager *LockManager) LockRelease(ctx context.Context, releaseName string) (lockgate.LockHandle, error)

+ func (lockManager *LockManager) Unlock(handle lockgate.LockHandle) error