KubernetesLock#unlock()
This commit is contained in:
committed by
Ioannis Canellos
parent
0d33d26b6a
commit
3eab7fa49a
@@ -84,8 +84,7 @@ public class KubernetesLock implements Lock {
|
||||
|
||||
@Override
|
||||
public void unlock() {
|
||||
// TODO delete configmap for this lock
|
||||
// TODO consider only allowing lock release only from the same application and/or thread
|
||||
repository.delete(name);
|
||||
}
|
||||
|
||||
@Override
|
||||
|
||||
@@ -148,7 +148,9 @@ public class KubernetesLockTest {
|
||||
|
||||
@Test
|
||||
public void shouldUnlock() {
|
||||
lock.unlock();
|
||||
|
||||
verify(repository).delete(NAME);
|
||||
}
|
||||
|
||||
@Test(expected = UnsupportedOperationException.class)
|
||||
|
||||
Reference in New Issue
Block a user