func (c CommitterProbe) GetPrimaryKey() []byte {
	return c.primaryKey
}
GetPrimaryKey returns primary key of the committer.
package transaction
import (
	"bytes"
	"context"
	"sync/atomic"
	"time"
	"github.com/tikv/client-go/v2/internal/locate"
	"github.com/tikv/client-go/v2/internal/retry"
	"github.com/tikv/client-go/v2/internal/unionstore"
	"github.com/tikv/client-go/v2/tikvrpc"
	"github.com/tikv/client-go/v2/txnkv/txnsnapshot"
)
type TxnProbe struct {
	*KVTxn
}
func (txn TxnProbe) SetStartTS(ts uint64) {
	txn.startTS = ts
}
func (txn TxnProbe) GetCommitTS() uint64 {
	return txn.commitTS
}
func (txn TxnProbe) GetUnionStore() *unionstore.KVUnionStore {
	return txn.us
}
func (txn TxnProbe) IsAsyncCommit() bool {
	return txn.committer.isAsyncCommit()
}
func (txn TxnProbe) NewCommitter(sessionID uint64) (CommitterProbe, error) {
	committer, err := newTwoPhaseCommitterWithInit(txn.KVTxn, sessionID)
	return CommitterProbe{twoPhaseCommitter: committer}, err
}
func (txn TxnProbe) GetCommitter() CommitterProbe {
	return CommitterProbe{txn.committer}
}
func (txn TxnProbe) SetCommitter(committer CommitterProbe) {
	txn.committer = committer.twoPhaseCommitter
}
func (txn TxnProbe) CollectLockedKeys() [][]byte {
	return txn.collectLockedKeys()
}
func (txn TxnProbe) BatchGetSingleRegion(bo *retry.Backoffer, region locate.RegionVerID, keys [][]byte, collect func([]byte, []byte)) error {
	snapshot := txnsnapshot.SnapshotProbe{KVSnapshot: txn.GetSnapshot()}
	return snapshot.BatchGetSingleRegion(bo, region, keys, collect)
}
func (txn TxnProbe) NewScanner(start, end []byte, batchSize int, reverse bool) (*txnsnapshot.Scanner, error) {
	snapshot := txnsnapshot.SnapshotProbe{KVSnapshot: txn.GetSnapshot()}
	return snapshot.NewScanner(start, end, batchSize, reverse)
}
func (txn TxnProbe) GetStartTime() time.Time {
	return txn.startTime
}
func newTwoPhaseCommitterWithInit(txn *KVTxn, sessionID uint64) (*twoPhaseCommitter, error) {
	c, err := newTwoPhaseCommitter(txn, sessionID)
	if err != nil {
		return nil, err
	}
	if err = c.initKeysAndMutations(); err != nil {
		return nil, err
	}
	return c, nil
}
type CommitterProbe struct {
	*twoPhaseCommitter
}
func (c CommitterProbe) InitKeysAndMutations() error {
	return c.initKeysAndMutations()
}
func (c CommitterProbe) SetPrimaryKey(key []byte) {
	c.primaryKey = key
}