Versions in this module Expand all Collapse all v1 v1.0.9 Apr 20, 2018 Changes in this version + func CancelJobs(txn kv.Transaction, ids []int64) ([]error, error) + func CompareIndexData(txn kv.Transaction, t table.Table, idx table.Index) error + func CompareTableRecord(txn kv.Transaction, t table.Table, data []*RecordData, exact bool) error + func GetDDLJobs(txn kv.Transaction) ([]*model.Job, error) + func GetHistoryDDLJobs(txn kv.Transaction) ([]*model.Job, error) + func GetIndexRecordsCount(txn kv.Transaction, kvIndex table.Index, startVals []types.Datum) (int64, error) + func GetTableRecordsCount(txn kv.Transaction, t table.Table, startHandle int64) (int64, error) + type DDLInfo struct + Job *model.Job + ReorgHandle int64 + SchemaVer int64 + func GetDDLInfo(txn kv.Transaction) (*DDLInfo, error) + type RecordData struct + Handle int64 + Values []types.Datum + func ScanIndexData(txn kv.Transaction, kvIndex table.Index, startVals []types.Datum, limit int64) ([]*RecordData, []types.Datum, error) + func ScanSnapshotTableRecord(store kv.Storage, ver kv.Version, t table.Table, startHandle, limit int64) ([]*RecordData, int64, error) + func ScanTableRecord(retriever kv.Retriever, t table.Table, startHandle, limit int64) ([]*RecordData, int64, error)
Go to main page