package tikv_cdc

import (
	"fmt"
)

const (
	MAX_KV_CNT int64 = 1e8
)

func GenerateTestData(prefix string, keyIndex int64) (key, value0, value1 []byte) {
	key = []byte(fmt.Sprintf("%sindexInfo_:_pf01_:_APD0101_:_%019d", prefix, keyIndex))
	value0 = []byte(fmt.Sprintf("v0%020d", keyIndex))
	value1 = []byte(fmt.Sprintf("v1_%020d%020d", keyIndex, keyIndex))
	return key, value0, value1
}

func BatchGenerateData(prefix string, keyIndex int64, keyCnt int64) (keys, values0, values1 [][]byte) {
	keys = make([][]byte, 0, keyCnt)
	values0 = make([][]byte, 0, keyCnt)
	values1 = make([][]byte, 0, keyCnt)
	for idx := keyIndex; idx < keyIndex+keyCnt; idx++ {
		key, value0, value1 := GenerateTestData(prefix, idx)
		keys = append(keys, key)
		values0 = append(values0, value0)
		values1 = append(values1, value1)
	}
	return keys, values0, values1
}