distributed_locker

package

Go to main page

Versions in this module

v0

v0.2.0

Jul 4, 2026

Changes in this version

type AcquireOptions

+ AcquirerId string

type DistributedLocker

+ func (l *DistributedLocker) HoldLease(lockName string, uuid string)

type LockLeaseRecord

+ QueueMembers map[string]*QueueMember

type OptimisticLockingStorageBasedBackend

+ func (backend *OptimisticLockingStorageBasedBackend) TakeIfOldest(handle lockgate.LockHandle, acquirerId string) (*LockLeaseRecord, error)

+ func (backend *OptimisticLockingStorageBasedBackend) UpdateQueue(handle lockgate.LockHandle, acquirerId string) error

+ type QueueMember struct

+ AcquiredAtTimestamp int64

+ AcquirerId string

+ ExpireAtTimestamp int64

v0.1.1

Mar 17, 2023

v0.1.0

Oct 4, 2021

Changes in this version

+ const DistributedLockLeaseRenewPeriodSeconds

+ const DistributedLockLeaseTTLSeconds

+ const DistributedLockPollRetryPeriodSeconds

+ const DistributedOptimisticLockingRetryPeriodSeconds

+ var ErrLockAlreadyLeased = errors.New("lock already leased")

+ var ErrNoExistingLockLeaseFound = errors.New("no existing lock lease found")

+ var ErrShouldWait = errors.New("should wait")

+ func IsErrLockAlreadyLeased(err error) bool

+ func IsErrNoExistingLockLeaseFound(err error) bool

+ func IsErrShouldWait(err error) bool

+ func RunHttpBackendServer(ip, port string, backend DistributedLockerBackend) error

+ type AcquireOptions struct

+ Shared bool

+ type AcquireRequest struct

+ LockName string

+ Opts AcquireOptions

+ type AcquireResponse struct

+ Err util.SerializableError

+ LockHandle lockgate.LockHandle

+ type DistributedLocker struct

+ Backend DistributedLockerBackend

+ func NewDistributedLocker(backend DistributedLockerBackend) *DistributedLocker

+ func NewHttpLocker(urlEndpoint string) *DistributedLocker

+ func NewKubernetesLocker(kubernetesInterface dynamic.Interface, gvr schema.GroupVersionResource, ...) *DistributedLocker

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

+ func (l *DistributedLocker) Release(handle lockgate.LockHandle) error

+ type DistributedLockerBackend interface

+ Acquire func(lockName string, opts AcquireOptions) (lockgate.LockHandle, error)

+ Release func(handle lockgate.LockHandle) error

+ RenewLease func(handle lockgate.LockHandle) error

+ type HttpBackend struct

+ HttpClient *http.Client

+ URLEndpoint string

+ func NewHttpBackend(urlEndpoint string) *HttpBackend

+ func (backend *HttpBackend) Acquire(lockName string, opts AcquireOptions) (lockgate.LockHandle, error)

+ func (backend *HttpBackend) Release(handle lockgate.LockHandle) error

+ func (backend *HttpBackend) RenewLease(handle lockgate.LockHandle) error

+ type HttpBackendHandler struct

+ Backend DistributedLockerBackend

+ func NewHttpBackendHandler(backend DistributedLockerBackend) *HttpBackendHandler

+ func NewHttpBackendHandlerWithInMemoryStore() *HttpBackendHandler

+ func NewHttpBackendHandlerWithKubernetesStore(kubernetesInterface dynamic.Interface, gvr schema.GroupVersionResource, ...) *HttpBackendHandler

+ type LeaseRenewWorkerDescriptor struct

+ DoneChan chan struct{}

+ SharedLeaseCounter int64

+ type LockLeaseRecord struct

+ ExpireAtTimestamp int64

+ IsShared bool

+ SharedHoldersCount int64

+ func NewLockLeaseRecord(lockName string, isShared bool) *LockLeaseRecord

+ type OptimisticLockingStorageBasedBackend struct

+ Store optimistic_locking_store.OptimisticLockingStore

+ func NewOptimisticLockingStorageBasedBackend(store optimistic_locking_store.OptimisticLockingStore) *OptimisticLockingStorageBasedBackend

+ func (backend *OptimisticLockingStorageBasedBackend) Acquire(lockName string, opts AcquireOptions) (lockgate.LockHandle, error)

+ func (backend *OptimisticLockingStorageBasedBackend) Release(handle lockgate.LockHandle) error

+ func (backend *OptimisticLockingStorageBasedBackend) RenewLease(handle lockgate.LockHandle) error

+ type ReleaseRequest struct

+ LockHandle lockgate.LockHandle

+ type ReleaseResponse struct

+ Err util.SerializableError

+ type RenewLeaseRequest struct

+ LockHandle lockgate.LockHandle

+ type RenewLeaseResponse struct

+ Err util.SerializableError

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL