txnkv

Documentation

Index

• Constants
• type BinlogWriteResult
• type Client
  • func NewClient(pdAddrs []string) (*Client, error)
  • func (c *Client) GetTimestamp(ctx context.Context) (uint64, error)
• type IsoLevel
• type KVFilter
• type KVSnapshot
• type KVTxn
• type Lock
  • func NewLock(l *kvrpcpb.LockInfo) *Lock
• type LockResolver
• type Priority
• type ReplicaReadAdjuster
• type Scanner
• type SchemaAmender
• type SchemaLeaseChecker
• type SchemaVer
• type SnapshotRuntimeStats
• type TxnStatus

Constants

const (
	SI        = txnsnapshot.SI
	RC        = txnsnapshot.RC
	RCCheckTS = txnsnapshot.RCCheckTS
)

IsoLevel value for transaction priority.

const (
	PriorityHigh   = txnutil.PriorityHigh
	PriorityNormal = txnutil.PriorityNormal
	PriorityLow    = txnutil.PriorityLow
)

Priority value for transaction priority.

const MaxTxnTimeUse = transaction.MaxTxnTimeUse

MaxTxnTimeUse is the max time a Txn may use (in ms) from its begin to commit. We use it to abort the transaction to guarantee GC worker will not influence it.

Types

type BinlogWriteResult

type BinlogWriteResult = transaction.BinlogWriteResult

BinlogWriteResult defines the result of prewrite binlog.

type Client

type Client struct {
	*tikv.KVStore
}

Client is a txn client.

func NewClient

func NewClient(pdAddrs []string) (*Client, error)

NewClient creates a txn client with pdAddrs.

func (*Client) GetTimestamp

func (c *Client) GetTimestamp(ctx context.Context) (uint64, error)

GetTimestamp returns the current global timestamp.

type IsoLevel

type IsoLevel = txnsnapshot.IsoLevel

IsoLevel is the transaction's isolation level.

type KVFilter

type KVFilter = transaction.KVFilter

KVFilter is a filter that filters out unnecessary KV pairs.

type KVSnapshot

type KVSnapshot = txnsnapshot.KVSnapshot

KVSnapshot implements the tidbkv.Snapshot interface.

type KVTxn

type KVTxn = transaction.KVTxn

KVTxn contains methods to interact with a TiKV transaction.

type Lock

type Lock = txnlock.Lock

Lock represents a lock from tikv server.

func NewLock

func NewLock(l *kvrpcpb.LockInfo) *Lock

NewLock creates a new *Lock.

type LockResolver

type LockResolver = txnlock.LockResolver

LockResolver resolves locks and also caches resolved txn status.

type Priority

type Priority = txnutil.Priority

Priority is the priority for tikv to execute a command.

type ReplicaReadAdjuster

type ReplicaReadAdjuster = txnsnapshot.ReplicaReadAdjuster

ReplicaReadAdjuster is a function that adjust the StoreSelectorOption and ReplicaReadType based on the keys count for BatchPointGet and PointGet

type Scanner

type Scanner = txnsnapshot.Scanner

Scanner support tikv scan

type SchemaAmender

type SchemaAmender = transaction.SchemaAmender

SchemaAmender is used by pessimistic transactions to amend commit mutations for schema change during 2pc.

type SchemaLeaseChecker

type SchemaLeaseChecker = transaction.SchemaLeaseChecker

SchemaLeaseChecker is used to validate schema version is not changed during transaction execution.

type SchemaVer

type SchemaVer = transaction.SchemaVer

SchemaVer is the infoSchema which will return the schema version.

type SnapshotRuntimeStats

type SnapshotRuntimeStats = txnsnapshot.SnapshotRuntimeStats

SnapshotRuntimeStats records the runtime stats of snapshot.

type TxnStatus

type TxnStatus = txnlock.TxnStatus

TxnStatus represents a txn's final status. It should be Lock or Commit or Rollback.