distributed_locker

type AcquireOptions struct {
	Shared bool `json:"shared"`
}

type AcquireRequest struct {
	LockName string         `json:"lockName"`
	Opts     AcquireOptions `json:"opts"`
}

type AcquireResponse struct {
	LockHandle lockgate.LockHandle    `json:"lockHandle"`
	Err        util.SerializableError `json:"err"`
}

type DistributedLocker struct {
	Backend DistributedLockerBackend
	// contains filtered or unexported fields
}

type DistributedLockerBackend interface {
	Acquire(lockName string, opts AcquireOptions) (lockgate.LockHandle, error)
	RenewLease(handle lockgate.LockHandle) error
	Release(handle lockgate.LockHandle) error
}

type HttpBackend struct {
	URLEndpoint string
	HttpClient  *http.Client
}

type HttpBackendHandler struct {
	*http.ServeMux
	Backend DistributedLockerBackend
}

type LeaseRenewWorkerDescriptor struct {
	DoneChan           chan struct{}
	SharedLeaseCounter int64
}

type LockLeaseRecord struct {
	lockgate.LockHandle
	ExpireAtTimestamp  int64
	SharedHoldersCount int64
	IsShared           bool
}

type OptimisticLockingStorageBasedBackend struct {
	Store optimistic_locking_store.OptimisticLockingStore
}

type ReleaseRequest struct {
	LockHandle lockgate.LockHandle `json:"lockHandle"`
}

type ReleaseResponse struct {
	Err util.SerializableError `json:"err"`
}

type RenewLeaseRequest struct {
	LockHandle lockgate.LockHandle `json:"lockHandle"`
}

type RenewLeaseResponse struct {
	Err util.SerializableError `json:"err"`
}