org.tikv.txn

Class TxnKVClient

java.lang.Object

org.tikv.txn.TxnKVClient

All Implemented Interfaces:

AutoCloseable

public class TxnKVClient
extends Object
implements AutoCloseable

KV client of transaction APIs for GET/PUT/DELETE/SCAN

Constructor Summary

Constructors

Constructor and Description
TxnKVClient(TiConfiguration conf, RegionStoreClient.RegionStoreClientBuilder clientBuilder, ReadOnlyPDClient pdClient)

Method Summary

Modifier and Type	Method and Description
void	close()
ClientRPCResult	commit(BackOffer backOffer, com.google.protobuf.ByteString[] keys, long startTs, long commitTs, TiRegion tiRegion, TiStore store) Commit request of 2pc, add backoff logic when encountered region error, ErrBodyMissing, and other errors
TiConfiguration	getConf()
RegionManager	getRegionManager()
TiTimestamp	getTimestamp()
ClientRPCResult	prewrite(BackOffer backOffer, List<Kvrpcpb.Mutation> mutations, com.google.protobuf.ByteString primary, long lockTTL, long startTs, TiRegion tiRegion, TiStore store) when encountered region error,ErrBodyMissing, and other errors
ClientRPCResult	txnHeartBeat(BackOffer backOffer, com.google.protobuf.ByteString primaryLock, long startTs, long ttl, TiRegion tiRegion, TiStore store) TXN Heart Beat: update primary key ttl

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

TxnKVClient

public TxnKVClient(TiConfiguration conf,
                   RegionStoreClient.RegionStoreClientBuilder clientBuilder,
                   ReadOnlyPDClient pdClient)

Method Detail

getConf

public TiConfiguration getConf()

getRegionManager

public RegionManager getRegionManager()

getTimestamp

public TiTimestamp getTimestamp()

prewrite

public ClientRPCResult prewrite(BackOffer backOffer,
                                List<Kvrpcpb.Mutation> mutations,
                                com.google.protobuf.ByteString primary,
                                long lockTTL,
                                long startTs,
                                TiRegion tiRegion,
                                TiStore store)

when encountered region error,ErrBodyMissing, and other errors

txnHeartBeat

public ClientRPCResult txnHeartBeat(BackOffer backOffer,
                                    com.google.protobuf.ByteString primaryLock,
                                    long startTs,
                                    long ttl,
                                    TiRegion tiRegion,
                                    TiStore store)

TXN Heart Beat: update primary key ttl

commit

public ClientRPCResult commit(BackOffer backOffer,
                              com.google.protobuf.ByteString[] keys,
                              long startTs,
                              long commitTs,
                              TiRegion tiRegion,
                              TiStore store)

Commit request of 2pc, add backoff logic when encountered region error, ErrBodyMissing, and other errors

Parameters:

backOffer -

keys -

startTs -

commitTs -

tiRegion -

Returns:

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception