asyncloaddata

type Job struct {
	ID int64
	// Job don't manage the life cycle of the connection.
	Conn sqlexec.SQLExecutor
	User string
}

type JobExpectedStatus int

type JobInfo struct {
	JobID         int64
	User          string
	DataSource    string
	TableSchema   string
	TableName     string
	ImportMode    string
	Progress      string
	Status        JobStatus
	StatusMessage string
	CreateTime    types.Time
	StartTime     types.Time
	EndTime       types.Time
}

type JobStatus int

type LogicalImportProgress struct {
	// LoadedFileSize is the size of the data that's loaded in bytes. It's
	// larger than the actual loaded data size, but due to the fact that reading
	// is once-a-block and a block may generate multiple tasks that are
	// concurrently executed, we can't know the actual loaded data size easily.
	LoadedFileSize atomic.Int64
}

type PhysicalImportProgress struct {
	// ReadRowCnt is the number of rows read from data files.
	// Lines ignored by IGNORE N LINES clause is not included.
	ReadRowCnt atomic.Uint64
	// EncodeFileSize is the size of the file that has finished KV encoding in bytes.
	// it should equal to SourceFileSize eventually.
	EncodeFileSize atomic.Int64
}

type Progress struct {
	// SourceFileSize is the size of the source file in bytes. When we can't get
	// the size of the source file, it will be set to -1.
	// Currently, the value is read by seek(0, end), when LOAD DATA LOCAL we wrap
	// SimpleSeekerOnReadCloser on MySQL client connection which doesn't support
	// it.
	SourceFileSize          int64
	*LogicalImportProgress  `json:",inline"`
	*PhysicalImportProgress `json:",inline"`
	// LoadedRowCnt is the number of rows that has been loaded.
	// for physical mode, it's the number of rows that has been imported into TiKV.
	// in SHOW LOAD JOB we call it Imported_Rows, to make it compatible with 7.0,
	// the variable name is not changed.
	LoadedRowCnt atomic.Uint64
}