Documentation
¶
Index ¶
- type IngestIndexInfo
- type IngestRecorder
- func (i *IngestRecorder) AddJob(job *model.Job) error
- func (i *IngestRecorder) Iterate(f func(tableID int64, indexID int64, info *IngestIndexInfo) error) error
- func (i *IngestRecorder) RewriteTableID(rewriteFunc func(tableID int64) (int64, bool, error)) error
- func (i *IngestRecorder) UpdateIndexInfo(dbInfos []*model.DBInfo)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type IngestIndexInfo ¶
type IngestIndexInfo struct {
SchemaName model.CIStr
TableName model.CIStr
ColumnList string
ColumnArgs []interface{}
IsPrimary bool
IndexInfo *model.IndexInfo
Updated bool
}
IngestIndexInfo records the information used to generate index drop/re-add SQL.
type IngestRecorder ¶
type IngestRecorder struct {
// contains filtered or unexported fields
}
IngestRecorder records the indexes information that use ingest mode to construct kvs. Currently log backup cannot backed up these ingest kvs. So need to re-construct them.
func (*IngestRecorder) AddJob ¶
func (i *IngestRecorder) AddJob(job *model.Job) error
AddJob firstly filters the ingest index add operation job, and records it into IngestRecorder.
func (*IngestRecorder) Iterate ¶
func (i *IngestRecorder) Iterate(f func(tableID int64, indexID int64, info *IngestIndexInfo) error) error
Iterate iterates all the ingest index.
func (*IngestRecorder) RewriteTableID ¶
RewriteTableID rewrites the table id of the items in the IngestRecorder
func (*IngestRecorder) UpdateIndexInfo ¶
func (i *IngestRecorder) UpdateIndexInfo(dbInfos []*model.DBInfo)
UpdateIndexInfo uses the newest schemas to update the ingest index's information
Source Files
Click to show internal directories.
Click to hide internal directories.