public class StandardLockInternalsDriver extends Object implements LockInternalsDriver
Constructor and Description |
---|
StandardLockInternalsDriver() |
Modifier and Type | Method and Description |
---|---|
String |
createsTheLock(CuratorFramework client,
String path,
byte[] lockNodeBytes) |
String |
fixForSorting(String str,
String lockName) |
protected String |
getSortingSequence() |
PredicateResults |
getsTheLock(CuratorFramework client,
List<String> children,
String sequenceNodeName,
int maxLeases) |
static String |
standardFixForSorting(String str,
String lockName) |
public PredicateResults getsTheLock(CuratorFramework client, List<String> children, String sequenceNodeName, int maxLeases) throws Exception
getsTheLock
in interface LockInternalsDriver
Exception
protected String getSortingSequence()
public String createsTheLock(CuratorFramework client, String path, byte[] lockNodeBytes) throws Exception
createsTheLock
in interface LockInternalsDriver
Exception
public String fixForSorting(String str, String lockName)
fixForSorting
in interface LockInternalsSorter
Copyright © 2011–2023 The Apache Software Foundation. All rights reserved.