Versions in this module Expand all Collapse all v1 v1.0.0 Oct 16, 2017 Changes in this version + const ExtraHandleID + type ActionType byte + const ActionAddColumn + const ActionAddForeignKey + const ActionAddIndex + const ActionCreateSchema + const ActionCreateTable + const ActionDropColumn + const ActionDropForeignKey + const ActionDropIndex + const ActionDropSchema + const ActionDropTable + const ActionModifyColumn + const ActionNone + const ActionRenameTable + const ActionSetDefaultValue + const ActionTruncateTable + func (action ActionType) String() string + type CIStr struct + L string + O string + func NewCIStr(s string) (cs CIStr) + func (cis CIStr) String() string + type ColumnInfo struct + Comment string + DefaultValue interface{} + Dependences map[string]struct{} + GeneratedExprString string + GeneratedStored bool + ID int64 + Name CIStr + Offset int + OriginDefaultValue interface{} + State SchemaState + func (c *ColumnInfo) Clone() *ColumnInfo + func (c *ColumnInfo) IsGenerated() bool + type DBInfo struct + Charset string + Collate string + ID int64 + Name CIStr + State SchemaState + Tables []*TableInfo + func (db *DBInfo) Clone() *DBInfo + type FKInfo struct + Cols []CIStr + ID int64 + Name CIStr + OnDelete int + OnUpdate int + RefCols []CIStr + RefTable CIStr + State SchemaState + func (fk *FKInfo) Clone() *FKInfo + type HistoryInfo struct + DBInfo *DBInfo + SchemaVersion int64 + TableInfo *TableInfo + func (h *HistoryInfo) AddDBInfo(schemaVer int64, dbInfo *DBInfo) + func (h *HistoryInfo) AddTableInfo(schemaVer int64, tblInfo *TableInfo) + func (h *HistoryInfo) Clean() + type IndexColumn struct + Length int + Name CIStr + Offset int + func (i *IndexColumn) Clone() *IndexColumn + type IndexInfo struct + Columns []*IndexColumn + Comment string + ID int64 + Name CIStr + Primary bool + State SchemaState + Table CIStr + Tp IndexType + Unique bool + func (index *IndexInfo) Clone() *IndexInfo + func (index *IndexInfo) HasPrefixIndex() bool + type IndexType int + const IndexTypeBtree + const IndexTypeHash + const IndexTypeInvalid + func (t IndexType) String() string + type Job struct + Args []interface{} + BinlogInfo *HistoryInfo + Error *terror.Error + ErrorCount int64 + ID int64 + LastUpdateTS int64 + Mu sync.Mutex + Query string + RawArgs json.RawMessage + RowCount int64 + SchemaID int64 + SchemaState SchemaState + SnapshotVer uint64 + State JobState + TableID int64 + Type ActionType + Version int64 + func (job *Job) Decode(b []byte) error + func (job *Job) DecodeArgs(args ...interface{}) error + func (job *Job) Encode(updateRawArgs bool) ([]byte, error) + func (job *Job) GetRowCount() int64 + func (job *Job) IsCancelled() bool + func (job *Job) IsDone() bool + func (job *Job) IsFinished() bool + func (job *Job) IsRunning() bool + func (job *Job) IsSynced() bool + func (job *Job) SetRowCount(count int64) + func (job *Job) String() string + type JobState byte + const JobCancelled + const JobDone + const JobNone + const JobRollback + const JobRollbackDone + const JobRunning + const JobSynced + func (s JobState) String() string + type SchemaDiff struct + OldSchemaID int64 + OldTableID int64 + SchemaID int64 + TableID int64 + Type ActionType + Version int64 + type SchemaState byte + const StateDeleteOnly + const StateDeleteReorganization + const StateNone + const StatePublic + const StateWriteOnly + const StateWriteReorganization + func (s SchemaState) String() string + type TableInfo struct + AutoIncID int64 + Charset string + Collate string + Columns []*ColumnInfo + Comment string + ForeignKeys []*FKInfo + ID int64 + Indices []*IndexInfo + MaxColumnID int64 + MaxIndexID int64 + Name CIStr + OldSchemaID int64 + PKIsHandle bool + State SchemaState + func (t *TableInfo) Clone() *TableInfo + func (t *TableInfo) ColumnIsInIndex(c *ColumnInfo) bool + func (t *TableInfo) GetPkColInfo() *ColumnInfo + func (t *TableInfo) GetPkName() CIStr