util

package

v1.0.2 Latest Latest Go to latest Published: Nov 13, 2017 License: Apache-2.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

func CompleteDeleteRange(ctx context.Context, dr DelRangeTask) error

CompleteDeleteRange deletes a record from gc_delete_range table. NOTE: This function WILL NOT start and run in a new transaction internally.

func UpdateDeleteRange(ctx context.Context, dr DelRangeTask, newStartKey, oldStartKey kv.Key) error

UpdateDeleteRange is only for emulator.

type DelRangeTask struct {
	JobID, ElementID int64
	StartKey, EndKey []byte
}

DelRangeTask is for run delete-range command in gc_worker.

func LoadDeleteRanges(ctx context.Context, safePoint uint64) (ranges []DelRangeTask, _ error)

LoadDeleteRanges loads delete range tasks from gc_delete_range table.

func (t DelRangeTask) Range() ([]byte, []byte)

Range returns the range [start, end) to delete.