checksum

Documentation

Index

• func FastChecksum(ctx context.Context, backupMeta *backuppb.BackupMeta, ...) error
• type Executor
  • func (exec *Executor) Each(f func(*kv.Request) error) error
  • func (exec *Executor) Execute(ctx context.Context, client kv.Client, updateFn func()) (*tipb.ChecksumResponse, error)
  • func (exec *Executor) Len() int
  • func (exec *Executor) RawRequests() ([]*tipb.ChecksumRequest, error)
• type ExecutorBuilder
  • func NewExecutorBuilder(table *model.TableInfo, ts uint64) *ExecutorBuilder
  • func (builder *ExecutorBuilder) Build() (*Executor, error)
  • func (builder *ExecutorBuilder) SetConcurrency(conc uint) *ExecutorBuilder
  • func (builder *ExecutorBuilder) SetOldTable(oldTable *metautil.Table) *ExecutorBuilder

Functions

func FastChecksum

func FastChecksum(
	ctx context.Context, backupMeta *backuppb.BackupMeta, storage storage.ExternalStorage,
) error

FastChecksum checks whether the "local" checksum matches the checksum from TiKV.

Types

type Executor

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

Executor is a checksum executor.

func (*Executor) Each

func (exec *Executor) Each(f func(*kv.Request) error) error

Each executes the function to each requests in the executor.

func (*Executor) Execute

func (exec *Executor) Execute(
	ctx context.Context,
	client kv.Client,
	updateFn func(),
) (*tipb.ChecksumResponse, error)

Execute executes a checksum executor.

func (*Executor) Len

func (exec *Executor) Len() int

Len returns the total number of checksum requests.

func (*Executor) RawRequests

func (exec *Executor) RawRequests() ([]*tipb.ChecksumRequest, error)

RawRequests extracts the raw requests associated with this executor. This is mainly used for debugging only.

type ExecutorBuilder

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

ExecutorBuilder is used to build a "kv.Request".

func NewExecutorBuilder

func NewExecutorBuilder(table *model.TableInfo, ts uint64) *ExecutorBuilder

NewExecutorBuilder returns a new executor builder.

func (*ExecutorBuilder) Build

func (builder *ExecutorBuilder) Build() (*Executor, error)

Build builds a checksum executor.

func (*ExecutorBuilder) SetConcurrency

func (builder *ExecutorBuilder) SetConcurrency(conc uint) *ExecutorBuilder

SetConcurrency set the concurrency of the checksum executing.

func (*ExecutorBuilder) SetOldTable

func (builder *ExecutorBuilder) SetOldTable(oldTable *metautil.Table) *ExecutorBuilder

SetOldTable set a old table info to the builder.