Package | Description |
---|---|
org.tikv.kvproto | |
org.tikv.txn |
Modifier and Type | Method and Description |
---|---|
Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.Builder.build() |
Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.Builder.buildPartial() |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.getDefaultInstance() |
Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.getDefaultInstanceForType() |
Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.Builder.getDefaultInstanceForType() |
Kvrpcpb.LockInfo |
RaftCmdpb.ReadIndexResponseOrBuilder.getLocked()
The memory lock blocking this read at the leader
|
Kvrpcpb.LockInfo |
RaftCmdpb.ReadIndexResponse.getLocked()
The memory lock blocking this read at the leader
|
Kvrpcpb.LockInfo |
RaftCmdpb.ReadIndexResponse.Builder.getLocked()
The memory lock blocking this read at the leader
|
Kvrpcpb.LockInfo |
Coprocessor.ResponseOrBuilder.getLocked()
.kvrpcpb.LockInfo locked = 3; |
Kvrpcpb.LockInfo |
Coprocessor.Response.getLocked()
.kvrpcpb.LockInfo locked = 3; |
Kvrpcpb.LockInfo |
Coprocessor.Response.Builder.getLocked()
.kvrpcpb.LockInfo locked = 3; |
Kvrpcpb.LockInfo |
Kvrpcpb.ReadIndexResponseOrBuilder.getLocked()
If `locked` is set, this read request is blocked by a lock.
|
Kvrpcpb.LockInfo |
Kvrpcpb.ReadIndexResponse.getLocked()
If `locked` is set, this read request is blocked by a lock.
|
Kvrpcpb.LockInfo |
Kvrpcpb.ReadIndexResponse.Builder.getLocked()
If `locked` is set, this read request is blocked by a lock.
|
Kvrpcpb.LockInfo |
Kvrpcpb.KeyErrorOrBuilder.getLocked()
Client should backoff or cleanup the lock then retry.
|
Kvrpcpb.LockInfo |
Kvrpcpb.KeyError.getLocked()
Client should backoff or cleanup the lock then retry.
|
Kvrpcpb.LockInfo |
Kvrpcpb.KeyError.Builder.getLocked()
Client should backoff or cleanup the lock then retry.
|
Kvrpcpb.LockInfo |
Kvrpcpb.CheckTxnStatusResponseOrBuilder.getLockInfo()
.kvrpcpb.LockInfo lock_info = 6; |
Kvrpcpb.LockInfo |
Kvrpcpb.CheckTxnStatusResponse.getLockInfo()
.kvrpcpb.LockInfo lock_info = 6; |
Kvrpcpb.LockInfo |
Kvrpcpb.CheckTxnStatusResponse.Builder.getLockInfo()
.kvrpcpb.LockInfo lock_info = 6; |
Kvrpcpb.LockInfo |
Kvrpcpb.CheckSecondaryLocksResponseOrBuilder.getLocks(int index)
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
Kvrpcpb.LockInfo |
Kvrpcpb.CheckSecondaryLocksResponse.getLocks(int index)
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
Kvrpcpb.LockInfo |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.getLocks(int index)
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
Kvrpcpb.LockInfo |
Kvrpcpb.ScanLockResponseOrBuilder.getLocks(int index)
Info on all locks found by the scan.
|
Kvrpcpb.LockInfo |
Kvrpcpb.ScanLockResponse.getLocks(int index)
Info on all locks found by the scan.
|
Kvrpcpb.LockInfo |
Kvrpcpb.ScanLockResponse.Builder.getLocks(int index)
Info on all locks found by the scan.
|
Kvrpcpb.LockInfo |
Kvrpcpb.CheckLockObserverResponseOrBuilder.getLocks(int index)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.LockInfo |
Kvrpcpb.CheckLockObserverResponse.getLocks(int index)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.LockInfo |
Kvrpcpb.CheckLockObserverResponse.Builder.getLocks(int index)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.LockInfo |
Kvrpcpb.PhysicalScanLockResponseOrBuilder.getLocks(int index)
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.LockInfo |
Kvrpcpb.PhysicalScanLockResponse.getLocks(int index)
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.LockInfo |
Kvrpcpb.PhysicalScanLockResponse.Builder.getLocks(int index)
repeated .kvrpcpb.LockInfo locks = 2; |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseDelimitedFrom(InputStream input) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(byte[] data) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(ByteBuffer data) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(com.google.protobuf.ByteString data) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(com.google.protobuf.CodedInputStream input) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(InputStream input) |
static Kvrpcpb.LockInfo |
Kvrpcpb.LockInfo.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<Kvrpcpb.LockInfo> |
Kvrpcpb.CheckSecondaryLocksResponseOrBuilder.getLocksList()
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
List<Kvrpcpb.LockInfo> |
Kvrpcpb.CheckSecondaryLocksResponse.getLocksList()
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
List<Kvrpcpb.LockInfo> |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.getLocksList()
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
List<Kvrpcpb.LockInfo> |
Kvrpcpb.ScanLockResponseOrBuilder.getLocksList()
Info on all locks found by the scan.
|
List<Kvrpcpb.LockInfo> |
Kvrpcpb.ScanLockResponse.getLocksList()
Info on all locks found by the scan.
|
List<Kvrpcpb.LockInfo> |
Kvrpcpb.ScanLockResponse.Builder.getLocksList()
Info on all locks found by the scan.
|
List<Kvrpcpb.LockInfo> |
Kvrpcpb.CheckLockObserverResponseOrBuilder.getLocksList()
repeated .kvrpcpb.LockInfo locks = 3; |
List<Kvrpcpb.LockInfo> |
Kvrpcpb.CheckLockObserverResponse.getLocksList()
repeated .kvrpcpb.LockInfo locks = 3; |
List<Kvrpcpb.LockInfo> |
Kvrpcpb.CheckLockObserverResponse.Builder.getLocksList()
repeated .kvrpcpb.LockInfo locks = 3; |
List<Kvrpcpb.LockInfo> |
Kvrpcpb.PhysicalScanLockResponseOrBuilder.getLocksList()
repeated .kvrpcpb.LockInfo locks = 2; |
List<Kvrpcpb.LockInfo> |
Kvrpcpb.PhysicalScanLockResponse.getLocksList()
repeated .kvrpcpb.LockInfo locks = 2; |
List<Kvrpcpb.LockInfo> |
Kvrpcpb.PhysicalScanLockResponse.Builder.getLocksList()
repeated .kvrpcpb.LockInfo locks = 2; |
com.google.protobuf.Parser<Kvrpcpb.LockInfo> |
Kvrpcpb.LockInfo.getParserForType() |
static com.google.protobuf.Parser<Kvrpcpb.LockInfo> |
Kvrpcpb.LockInfo.parser() |
Modifier and Type | Method and Description |
---|---|
Kvrpcpb.CheckSecondaryLocksResponse.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.addLocks(int index,
Kvrpcpb.LockInfo value)
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
Kvrpcpb.ScanLockResponse.Builder |
Kvrpcpb.ScanLockResponse.Builder.addLocks(int index,
Kvrpcpb.LockInfo value)
Info on all locks found by the scan.
|
Kvrpcpb.CheckLockObserverResponse.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.addLocks(int index,
Kvrpcpb.LockInfo value)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.PhysicalScanLockResponse.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.addLocks(int index,
Kvrpcpb.LockInfo value)
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.CheckSecondaryLocksResponse.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.addLocks(Kvrpcpb.LockInfo value)
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
Kvrpcpb.ScanLockResponse.Builder |
Kvrpcpb.ScanLockResponse.Builder.addLocks(Kvrpcpb.LockInfo value)
Info on all locks found by the scan.
|
Kvrpcpb.CheckLockObserverResponse.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.addLocks(Kvrpcpb.LockInfo value)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.PhysicalScanLockResponse.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.addLocks(Kvrpcpb.LockInfo value)
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.mergeFrom(Kvrpcpb.LockInfo other) |
RaftCmdpb.ReadIndexResponse.Builder |
RaftCmdpb.ReadIndexResponse.Builder.mergeLocked(Kvrpcpb.LockInfo value)
The memory lock blocking this read at the leader
|
Coprocessor.Response.Builder |
Coprocessor.Response.Builder.mergeLocked(Kvrpcpb.LockInfo value)
.kvrpcpb.LockInfo locked = 3; |
Kvrpcpb.ReadIndexResponse.Builder |
Kvrpcpb.ReadIndexResponse.Builder.mergeLocked(Kvrpcpb.LockInfo value)
If `locked` is set, this read request is blocked by a lock.
|
Kvrpcpb.KeyError.Builder |
Kvrpcpb.KeyError.Builder.mergeLocked(Kvrpcpb.LockInfo value)
Client should backoff or cleanup the lock then retry.
|
Kvrpcpb.CheckTxnStatusResponse.Builder |
Kvrpcpb.CheckTxnStatusResponse.Builder.mergeLockInfo(Kvrpcpb.LockInfo value)
.kvrpcpb.LockInfo lock_info = 6; |
static Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.newBuilder(Kvrpcpb.LockInfo prototype) |
RaftCmdpb.ReadIndexResponse.Builder |
RaftCmdpb.ReadIndexResponse.Builder.setLocked(Kvrpcpb.LockInfo value)
The memory lock blocking this read at the leader
|
Coprocessor.Response.Builder |
Coprocessor.Response.Builder.setLocked(Kvrpcpb.LockInfo value)
.kvrpcpb.LockInfo locked = 3; |
Kvrpcpb.ReadIndexResponse.Builder |
Kvrpcpb.ReadIndexResponse.Builder.setLocked(Kvrpcpb.LockInfo value)
If `locked` is set, this read request is blocked by a lock.
|
Kvrpcpb.KeyError.Builder |
Kvrpcpb.KeyError.Builder.setLocked(Kvrpcpb.LockInfo value)
Client should backoff or cleanup the lock then retry.
|
Kvrpcpb.CheckTxnStatusResponse.Builder |
Kvrpcpb.CheckTxnStatusResponse.Builder.setLockInfo(Kvrpcpb.LockInfo value)
.kvrpcpb.LockInfo lock_info = 6; |
Kvrpcpb.CheckSecondaryLocksResponse.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.setLocks(int index,
Kvrpcpb.LockInfo value)
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
Kvrpcpb.ScanLockResponse.Builder |
Kvrpcpb.ScanLockResponse.Builder.setLocks(int index,
Kvrpcpb.LockInfo value)
Info on all locks found by the scan.
|
Kvrpcpb.CheckLockObserverResponse.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.setLocks(int index,
Kvrpcpb.LockInfo value)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.PhysicalScanLockResponse.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.setLocks(int index,
Kvrpcpb.LockInfo value)
repeated .kvrpcpb.LockInfo locks = 2; |
Modifier and Type | Method and Description |
---|---|
Kvrpcpb.CheckSecondaryLocksResponse.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.addAllLocks(Iterable<? extends Kvrpcpb.LockInfo> values)
For each key in `keys` in `CheckSecondaryLocks`, there will be a lock in
this list if there is a lock present and belonging to the correct transaction,
nil otherwise.
|
Kvrpcpb.ScanLockResponse.Builder |
Kvrpcpb.ScanLockResponse.Builder.addAllLocks(Iterable<? extends Kvrpcpb.LockInfo> values)
Info on all locks found by the scan.
|
Kvrpcpb.CheckLockObserverResponse.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.addAllLocks(Iterable<? extends Kvrpcpb.LockInfo> values)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.PhysicalScanLockResponse.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.addAllLocks(Iterable<? extends Kvrpcpb.LockInfo> values)
repeated .kvrpcpb.LockInfo locks = 2; |
Constructor and Description |
---|
Lock(Kvrpcpb.LockInfo l,
RequestKeyCodec codec) |
Copyright © 2024 PingCAP. All rights reserved.