checksum

Documentation

Index

• Constants
• func Run(ctx context.Context, cmdName string, executor *Executor, ...) error
• func UpdateChecksum(c *rawkv.RawChecksum, crc64Xor, totalKvs, totalBytes uint64)
• type Client
• type Executor
  • func NewExecutor(ctx context.Context, keyRanges []*utils.KeyRange, pdAddrs []string, ...) (*Executor, error)
  • func (exec *Executor) Close()
  • func (exec *Executor) Execute(ctx context.Context, expect rawkv.RawChecksum, method StorageChecksumMethod, ...) error
• type StorageChecksumMethod

Constants

const (
	MaxScanCntLimit = 1024 // limited by grpc message size
)

Functions

func Run

func Run(ctx context.Context, cmdName string,
	executor *Executor, method StorageChecksumMethod, expect rawkv.RawChecksum) error

func UpdateChecksum

func UpdateChecksum(c *rawkv.RawChecksum, crc64Xor, totalKvs, totalBytes uint64)

Types

type Client

type Client interface {
	Checksum(ctx context.Context, startKey, endKey []byte, options ...rawkv.RawOption) (check rawkv.RawChecksum, err error)
	Scan(ctx context.Context, startKey, endKey []byte, limit int, options ...rawkv.RawOption) (keys [][]byte, values [][]byte, err error)
	Close() error
}

type Executor

type Executor struct {
	// contains filtered or unexported fields
}

ExecutorBuilder is used to build

func NewExecutor

func NewExecutor(ctx context.Context, keyRanges []*utils.KeyRange, pdAddrs []string, apiVersion kvrpcpb.APIVersion,
	concurrency uint, tls utils.TLSConfig) (*Executor, error)

NewExecutorBuilder returns a new executor builder.

func (*Executor) Close

func (exec *Executor) Close()

func (*Executor) Execute

func (exec *Executor) Execute(
	ctx context.Context,
	expect rawkv.RawChecksum,
	method StorageChecksumMethod,
	progressCallBack func(backup.ProgressUnit),
) error

Execute executes a checksum executor.

type StorageChecksumMethod

type StorageChecksumMethod int32

const (
	StorageChecksumCommand StorageChecksumMethod = 0
	StorageScanCommand     StorageChecksumMethod = 1
)