Package | Description |
---|---|
org.tikv.kvproto |
Modifier and Type | Method and Description |
---|---|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.addAllSecondaries(Iterable<? extends com.google.protobuf.ByteString> values)
repeated bytes secondaries = 10; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.addLocksBuilder()
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.Builder |
Kvrpcpb.ScanLockResponse.Builder.addLocksBuilder()
Info on all locks found by the scan.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.addLocksBuilder()
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.addLocksBuilder()
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.addLocksBuilder(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.Builder |
Kvrpcpb.ScanLockResponse.Builder.addLocksBuilder(int index)
Info on all locks found by the scan.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.addLocksBuilder(int index)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.addLocksBuilder(int index)
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.addRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.addSecondaries(com.google.protobuf.ByteString value)
repeated bytes secondaries = 10; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clear() |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearField(com.google.protobuf.Descriptors.FieldDescriptor field) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearKey()
bytes key = 3; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearLockForUpdateTs()
uint64 lock_for_update_ts = 7; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearLockTtl()
uint64 lock_ttl = 4; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearLockType()
.kvrpcpb.Op lock_type = 6; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearLockVersion()
uint64 lock_version = 2; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearMinCommitTs()
uint64 min_commit_ts = 9; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearOneof(com.google.protobuf.Descriptors.OneofDescriptor oneof) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearPrimaryLock()
bytes primary_lock = 1; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearSecondaries()
repeated bytes secondaries = 10; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearTxnSize()
How many keys this transaction involves in this region.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clearUseAsyncCommit()
Fields for transactions that are using Async Commit.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.clone() |
Kvrpcpb.LockInfo.Builder |
RaftCmdpb.ReadIndexResponse.Builder.getLockedBuilder()
The memory lock blocking this read at the leader
|
Kvrpcpb.LockInfo.Builder |
Coprocessor.Response.Builder.getLockedBuilder()
.kvrpcpb.LockInfo locked = 3; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.ReadIndexResponse.Builder.getLockedBuilder()
If `locked` is set, this read request is blocked by a lock.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.KeyError.Builder.getLockedBuilder()
Client should backoff or cleanup the lock then retry.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.CheckTxnStatusResponse.Builder.getLockInfoBuilder()
.kvrpcpb.LockInfo lock_info = 6; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.getLocksBuilder(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.Builder |
Kvrpcpb.ScanLockResponse.Builder.getLocksBuilder(int index)
Info on all locks found by the scan.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.getLocksBuilder(int index)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.getLocksBuilder(int index)
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.mergeFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.mergeFrom(Kvrpcpb.LockInfo other) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.mergeFrom(com.google.protobuf.Message other) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.mergeUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
static Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.newBuilder() |
static Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.newBuilder(Kvrpcpb.LockInfo prototype) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.newBuilderForType() |
protected Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.newBuilderForType(com.google.protobuf.GeneratedMessageV3.BuilderParent parent) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setField(com.google.protobuf.Descriptors.FieldDescriptor field,
Object value) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setKey(com.google.protobuf.ByteString value)
bytes key = 3; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setLockForUpdateTs(long value)
uint64 lock_for_update_ts = 7; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setLockTtl(long value)
uint64 lock_ttl = 4; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setLockType(Kvrpcpb.Op value)
.kvrpcpb.Op lock_type = 6; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setLockTypeValue(int value)
.kvrpcpb.Op lock_type = 6; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setLockVersion(long value)
uint64 lock_version = 2; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setMinCommitTs(long value)
uint64 min_commit_ts = 9; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setPrimaryLock(com.google.protobuf.ByteString value)
bytes primary_lock = 1; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setRepeatedField(com.google.protobuf.Descriptors.FieldDescriptor field,
int index,
Object value) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setSecondaries(int index,
com.google.protobuf.ByteString value)
repeated bytes secondaries = 10; |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setTxnSize(long value)
How many keys this transaction involves in this region.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setUnknownFields(com.google.protobuf.UnknownFieldSet unknownFields) |
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.Builder.setUseAsyncCommit(boolean value)
Fields for transactions that are using Async Commit.
|
Kvrpcpb.LockInfo.Builder |
Kvrpcpb.LockInfo.toBuilder() |
Modifier and Type | Method and Description |
---|---|
List<Kvrpcpb.LockInfo.Builder> |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.getLocksBuilderList()
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.Builder> |
Kvrpcpb.ScanLockResponse.Builder.getLocksBuilderList()
Info on all locks found by the scan.
|
List<Kvrpcpb.LockInfo.Builder> |
Kvrpcpb.CheckLockObserverResponse.Builder.getLocksBuilderList()
repeated .kvrpcpb.LockInfo locks = 3; |
List<Kvrpcpb.LockInfo.Builder> |
Kvrpcpb.PhysicalScanLockResponse.Builder.getLocksBuilderList()
repeated .kvrpcpb.LockInfo locks = 2; |
Modifier and Type | Method and Description |
---|---|
Kvrpcpb.CheckSecondaryLocksResponse.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.addLocks(int index,
Kvrpcpb.LockInfo.Builder builderForValue)
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.Builder builderForValue)
Info on all locks found by the scan.
|
Kvrpcpb.CheckLockObserverResponse.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.addLocks(int index,
Kvrpcpb.LockInfo.Builder builderForValue)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.PhysicalScanLockResponse.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.addLocks(int index,
Kvrpcpb.LockInfo.Builder builderForValue)
repeated .kvrpcpb.LockInfo locks = 2; |
Kvrpcpb.CheckSecondaryLocksResponse.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.addLocks(Kvrpcpb.LockInfo.Builder builderForValue)
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.Builder builderForValue)
Info on all locks found by the scan.
|
Kvrpcpb.CheckLockObserverResponse.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.addLocks(Kvrpcpb.LockInfo.Builder builderForValue)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.PhysicalScanLockResponse.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.addLocks(Kvrpcpb.LockInfo.Builder builderForValue)
repeated .kvrpcpb.LockInfo locks = 2; |
RaftCmdpb.ReadIndexResponse.Builder |
RaftCmdpb.ReadIndexResponse.Builder.setLocked(Kvrpcpb.LockInfo.Builder builderForValue)
The memory lock blocking this read at the leader
|
Coprocessor.Response.Builder |
Coprocessor.Response.Builder.setLocked(Kvrpcpb.LockInfo.Builder builderForValue)
.kvrpcpb.LockInfo locked = 3; |
Kvrpcpb.ReadIndexResponse.Builder |
Kvrpcpb.ReadIndexResponse.Builder.setLocked(Kvrpcpb.LockInfo.Builder builderForValue)
If `locked` is set, this read request is blocked by a lock.
|
Kvrpcpb.KeyError.Builder |
Kvrpcpb.KeyError.Builder.setLocked(Kvrpcpb.LockInfo.Builder builderForValue)
Client should backoff or cleanup the lock then retry.
|
Kvrpcpb.CheckTxnStatusResponse.Builder |
Kvrpcpb.CheckTxnStatusResponse.Builder.setLockInfo(Kvrpcpb.LockInfo.Builder builderForValue)
.kvrpcpb.LockInfo lock_info = 6; |
Kvrpcpb.CheckSecondaryLocksResponse.Builder |
Kvrpcpb.CheckSecondaryLocksResponse.Builder.setLocks(int index,
Kvrpcpb.LockInfo.Builder builderForValue)
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.Builder builderForValue)
Info on all locks found by the scan.
|
Kvrpcpb.CheckLockObserverResponse.Builder |
Kvrpcpb.CheckLockObserverResponse.Builder.setLocks(int index,
Kvrpcpb.LockInfo.Builder builderForValue)
repeated .kvrpcpb.LockInfo locks = 3; |
Kvrpcpb.PhysicalScanLockResponse.Builder |
Kvrpcpb.PhysicalScanLockResponse.Builder.setLocks(int index,
Kvrpcpb.LockInfo.Builder builderForValue)
repeated .kvrpcpb.LockInfo locks = 2; |
Copyright © 2024 PingCAP. All rights reserved.