Injected kubernetes K8Factory need by the methods to create, renew, and delete leases.
Injected lock renewal service need to support automatic (background) lock renewals.
The holder of the lock.
The namespace in which the lease is to be acquired.
The name of the lease to be acquired; if not provided, the namespace is used.
The duration in seconds for which the lock is to be held; if not provided, the default value is used.
Readonlyk8Injected kubernetes K8Factory need by the methods to create, renew, and delete leases.
ReadonlyrenewalInjected lock renewal service need to support automatic (background) lock renewals.
Static ReadonlyDEFAULT_The default duration in seconds for which the lock is to be held before being considered expired.
The duration in seconds for which the lease is held before being considered expired. By default, the duration is set to 20 seconds. It is recommended to renew the lease at 50% of the duration to prevent unexpected expiration.
The name of the lease.
The holder of the lock.
The namespace in which the lease is to be acquired. By default, the namespace is used as the lease name. The defaults assume there is only a single deployment in a given namespace.
The identifier of the scheduled lease renewal task.
Internal setter for the scheduleId property. External callers should not use this method.
The identifier of the scheduled lease renewal task.
Acquires the lock. If the lock is already acquired, it checks if the lock is expired or held by the same process. If the lock is expired, it creates a new lock. If the lock is held by the same process, it renews the lock. If the lock is held by another process, then an exception is thrown.
Checks if the lock is acquired. If the lock is acquired and not expired, it returns true; otherwise, false.
true if the lock is acquired and not expired; otherwise, false.
Checks if the lock is expired. If the lock is expired, it returns true; otherwise, false. This method does not verify if the lock is acquired by the current process.
true if the lock is expired; otherwise, false.
Releases the lock. If the lock is expired or held by the same process, it deletes the lock. If the lock is held by another process, then an exception is thrown.
Renews the lock. If the lock is expired or held by the same process, it creates or renews the lock. If the lock is held by another process, then an exception is thrown.
Attempts to acquire the lock, by calling the acquire method. If an exception is thrown, it is caught and false is returned. If the lock is successfully acquired, true is returned; otherwise, false is returned.
true if the lock is successfully acquired; otherwise, false.
Attempts to release the lock, by calling the release method. If an exception is thrown, it is caught and false is returned. If the lock is successfully released, true is returned; otherwise, false is returned.
true if the lock is successfully released; otherwise, false.
Attempts to renew the lock, by calling the renew method. If an exception is thrown, it is caught and false is returned. If the lock is successfully renewed, true is returned; otherwise, false is returned.
true if the lock is successfully renewed; otherwise, false.
Concrete implementation of a Kubernetes time-based mutually exclusive lock via the Coordination API. Applies a namespace/deployment wide lock to ensure that only one process, machine, and user can hold the lock at a time. The lock is automatically renewed in the background to prevent expiration and ensure the holder maintains the lock. If the process die, the lock is automatically released after the lock duration.