checksum

Documentation

Index

• 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 *utils.Table) *ExecutorBuilder

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 *utils.Table) *ExecutorBuilder

SetOldTable set a old table info to the builder.