leaselocker

Aug 18, 2025

Changes in this version

type Config

+ UnlockWithRetryPeriod time.Duration

type LeaseLocker

+ func (l *LeaseLocker) UnlockWithRetry(ctx context.Context)

Oct 18, 2024

Changes in this version

+ func LeaseLockRecordToLeaseSpec(lr *LockRecord) v1.LeaseSpec

+ type Config struct

+ LeaseDuration time.Duration

+ Lock Interface

+ Name string

+ ReleaseOnCancel bool

+ RenewDeadline time.Duration

+ RetryPeriod time.Duration

+ UseObservedTime bool

+ type Interface interface

+ Create func(ctx context.Context, lr LockRecord) error

+ Describe func() string

+ Get func(ctx context.Context) (*LockRecord, []byte, error)

+ Identity func() string

+ RecordEvent func(string)

+ Update func(ctx context.Context, lr LockRecord) error

+ type LeaseLock struct

+ Client coordinationv1.LeasesGetter

+ LeaseMeta metav1.ObjectMeta

+ LockConfig ResourceLockConfig

+ func (ll *LeaseLock) Create(ctx context.Context, lr LockRecord) error

+ func (ll *LeaseLock) Describe() string

+ func (ll *LeaseLock) Get(ctx context.Context) (*LockRecord, []byte, error)

+ func (ll *LeaseLock) Identity() string

+ func (ll *LeaseLock) RecordEvent(s string)

+ func (ll *LeaseLock) Update(ctx context.Context, lr LockRecord) error

+ type LeaseLocker struct

+ func NewLeaseLocker(config *rest.Config, namespacedName types.NamespacedName, owner string) (*LeaseLocker, error)

+ func (l *LeaseLocker) Check(maxTolerableExpiredLease time.Duration) error

+ func (l *LeaseLocker) Lock(ctx context.Context)

+ func (l *LeaseLocker) TryLock(ctx context.Context) bool

+ func (l *LeaseLocker) Unlock()

+ type LockRecord struct

+ AcquireTime metav1.Time

+ HolderIdentity string

+ Identity string

+ LeaseDurationSeconds int

+ LeaseTransitions int

+ RenewTime metav1.Time

+ func LeaseSpecToLeaseLockRecord(spec *v1.LeaseSpec) *LockRecord

+ type ResourceLockConfig struct

+ EventRecorder record.EventRecorder

+ Identity string