checksum

package

v0.0.0-...-1b33b2a Latest Latest Go to latest Published: Mar 5, 2024 License: Apache-2.0, Apache-2.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tikv/migration

Links

Open Source Insights

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 ¶

View Source

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

Variables ¶

This section is empty.

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
)

Source Files ¶

View all Source files

executor.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL