checkpoint

type BackupKeyType = string

type BackupValueType = RangeType

type CheckpointData struct {
	DureTime        time.Duration     `json:"dure-time"`
	RangeGroupMetas []*RangeGroupData `json:"range-group-metas"`
}

type CheckpointIngestIndexRepairSQL struct {
	IndexID    int64         `json:"index-id"`
	SchemaName model.CIStr   `json:"schema-name"`
	TableName  model.CIStr   `json:"table-name"`
	IndexName  string        `json:"index-name"`
	AddSQL     string        `json:"add-sql"`
	AddArgs    []interface{} `json:"add-args"`
}

type CheckpointIngestIndexRepairSQLs struct {
	SQLs []CheckpointIngestIndexRepairSQL
}

type CheckpointLock struct {
	LockId   uint64 `json:"lock-id"`
	ExpireAt int64  `json:"expire-at"`
}

type CheckpointMessage[K KeyType, V ValueType] struct {
	// start-key of the origin range
	GroupKey K

	Group []V
}

type CheckpointMetadataForBackup struct {
	GCServiceId string        `json:"gc-service-id"`
	ConfigHash  []byte        `json:"config-hash"`
	BackupTS    uint64        `json:"backup-ts"`
	Ranges      []rtree.Range `json:"ranges"`

	CheckpointChecksum map[int64]*ChecksumItem    `json:"-"`
	CheckpointDataMap  map[string]rtree.RangeTree `json:"-"`
}

type CheckpointMetadataForRestore struct {
	SchedulersConfig *pdutil.ClusterConfig `json:"schedulers-config,omitempty"`
	GcRatio          string                `json:"gc-ratio,omitempty"`
}

type CheckpointRunner[K KeyType, V ValueType] struct {
	// contains filtered or unexported fields
}

type CheckpointTaskInfoForLogRestore struct {
	// the progress for this task
	Progress RestoreProgress `json:"progress"`
	// a task marker to distinguish the different tasks
	StartTS   uint64 `json:"start-ts"`
	RestoreTS uint64 `json:"restore-ts"`
	// updated in the progress of `InLogRestoreAndIdMapPersist`
	RewriteTS uint64 `json:"rewrite-ts"`
	// tiflash recorder items with snapshot restore records
	TiFlashItems map[int64]model.TiFlashReplicaInfo `json:"tiflash-recorder,omitempty"`
}

type ChecksumInfo struct {
	Content  []byte        `json:"content"`
	Checksum []byte        `json:"checksum"`
	DureTime time.Duration `json:"dure-time"`
}

type ChecksumItem struct {
	TableID    int64  `json:"table-id"`
	Crc64xor   uint64 `json:"crc64-xor"`
	TotalKvs   uint64 `json:"total-kvs"`
	TotalBytes uint64 `json:"total-bytes"`
}

type ChecksumItems struct {
	Items []*ChecksumItem `json:"checksum-items"`
}

type GlobalTimer interface {
	GetTS(context.Context) (int64, int64, error)
}

type KeyType interface {
	~BackupKeyType | ~RestoreKeyType
}

type LogRestoreKeyType = string

type LogRestoreValueMarshaled struct {
	// group index in the metadata
	Goff int `json:"goff"`
	// downstream table id -> file indexes in the group
	Foffs map[int64][]int `json:"foffs"`
}

type LogRestoreValueType struct {
	// downstream table id
	TableID int64
	// group index in the metadata
	Goff int
	// file index in the group
	Foff int
}

type RangeGroup[K KeyType, V ValueType] struct {
	GroupKey K   `json:"group-key"`
	Group    []V `json:"groups"`
}

type RangeGroupData struct {
	RangeGroupsEncriptedData []byte
	Checksum                 []byte
	CipherIv                 []byte

	Size int
}

type RangeType struct {
	*rtree.Range
}

type RestoreKeyType = int64

type RestoreProgress int

type RestoreValueType struct {
	// the file key of a range
	RangeKey string
}

type TimeTicker interface {
	Ch() <-chan time.Time
	Stop()
}

type ValueType interface {
	IdentKey() []byte
}