Documentation
¶
Index ¶
- Variables
- type Meta
- func (m *Meta) AddHistoryDDLJob(job *model.Job) error
- func (m *Meta) CreateDatabase(dbInfo *model.DBInfo) error
- func (m *Meta) CreateTable(dbID int64, tableInfo *model.TableInfo) error
- func (m *Meta) DDLJobQueueLen() (int64, error)
- func (m *Meta) DeQueueDDLJob() (*model.Job, error)
- func (m *Meta) DropDatabase(dbID int64) error
- func (m *Meta) DropTable(dbID int64, tableID int64, delAutoID bool) error
- func (m *Meta) EnQueueDDLJob(job *model.Job) error
- func (m *Meta) FinishBootstrap(version int64) error
- func (m *Meta) GenAutoTableID(dbID int64, tableID int64, step int64) (int64, error)
- func (m *Meta) GenGlobalID() (int64, error)
- func (m *Meta) GenSchemaVersion() (int64, error)
- func (m *Meta) GetAllHistoryDDLJobs() ([]*model.Job, error)
- func (m *Meta) GetAutoTableID(dbID int64, tableID int64) (int64, error)
- func (m *Meta) GetBootstrapVersion() (int64, error)
- func (m *Meta) GetDDLJob(index int64) (*model.Job, error)
- func (m *Meta) GetDDLReorgHandle(job *model.Job) (int64, error)
- func (m *Meta) GetDatabase(dbID int64) (*model.DBInfo, error)
- func (m *Meta) GetGlobalID() (int64, error)
- func (m *Meta) GetHistoryDDLJob(id int64) (*model.Job, error)
- func (m *Meta) GetSchemaDiff(schemaVersion int64) (*model.SchemaDiff, error)
- func (m *Meta) GetSchemaVersion() (int64, error)
- func (m *Meta) GetTable(dbID int64, tableID int64) (*model.TableInfo, error)
- func (m *Meta) ListDatabases() ([]*model.DBInfo, error)
- func (m *Meta) ListTables(dbID int64) ([]*model.TableInfo, error)
- func (m *Meta) RemoveDDLReorgHandle(job *model.Job) error
- func (m *Meta) SetSchemaDiff(diff *model.SchemaDiff) error
- func (m *Meta) UpdateDDLJob(index int64, job *model.Job) error
- func (m *Meta) UpdateDDLReorgHandle(job *model.Job, handle int64) error
- func (m *Meta) UpdateDatabase(dbInfo *model.DBInfo) error
- func (m *Meta) UpdateTable(dbID int64, tableInfo *model.TableInfo) error
Constants ¶
This section is empty.
Variables ¶
var ( // ErrDBExists is the error for db exists. ErrDBExists = terror.ClassMeta.New(codeDatabaseExists, "database already exists") // ErrDBNotExists is the error for db not exists. ErrDBNotExists = terror.ClassMeta.New(codeDatabaseNotExists, "database doesn't exist") // ErrTableExists is the error for table exists. ErrTableExists = terror.ClassMeta.New(codeTableExists, "table already exists") // ErrTableNotExists is the error for table not exists. ErrTableNotExists = terror.ClassMeta.New(codeTableNotExists, "table doesn't exist") )
Functions ¶
This section is empty.
Types ¶
type Meta ¶
type Meta struct {
// contains filtered or unexported fields
}
Meta is for handling meta information in a transaction.
func NewSnapshotMeta ¶
NewSnapshotMeta creates a Meta with snapshot.
func (*Meta) AddHistoryDDLJob ¶
AddHistoryDDLJob adds DDL job to history.
func (*Meta) CreateDatabase ¶
CreateDatabase creates a database with db info.
func (*Meta) CreateTable ¶
CreateTable creates a table with tableInfo in database.
func (*Meta) DDLJobQueueLen ¶
DDLJobQueueLen returns the DDL job queue length.
func (*Meta) DeQueueDDLJob ¶
DeQueueDDLJob pops a DDL job from the list.
func (*Meta) DropDatabase ¶
DropDatabase drops whole database.
func (*Meta) DropTable ¶
DropTable drops table in database. If delAutoID is true, it will delete the auto_increment id key-value of the table. For rename table, we do not need to rename auto_increment id key-value.
func (*Meta) EnQueueDDLJob ¶
EnQueueDDLJob adds a DDL job to the list.
func (*Meta) FinishBootstrap ¶
FinishBootstrap finishes bootstrap.
func (*Meta) GenAutoTableID ¶
GenAutoTableID adds step to the auto id of the table and returns the sum.
func (*Meta) GenGlobalID ¶
GenGlobalID generates next id globally.
func (*Meta) GenSchemaVersion ¶
GenSchemaVersion generates next schema version.
func (*Meta) GetAllHistoryDDLJobs ¶
GetAllHistoryDDLJobs gets all history DDL jobs.
func (*Meta) GetAutoTableID ¶
GetAutoTableID gets current auto id with table id.
func (*Meta) GetBootstrapVersion ¶
GetBootstrapVersion returns the version of the server which boostrap the store. If the store is not bootstraped, the version will be zero.
func (*Meta) GetDDLReorgHandle ¶
GetDDLReorgHandle gets the latest processed handle.
func (*Meta) GetDatabase ¶
GetDatabase gets the database value with ID.
func (*Meta) GetGlobalID ¶
GetGlobalID gets current global id.
func (*Meta) GetHistoryDDLJob ¶
GetHistoryDDLJob gets a history DDL job.
func (*Meta) GetSchemaDiff ¶
func (m *Meta) GetSchemaDiff(schemaVersion int64) (*model.SchemaDiff, error)
GetSchemaDiff gets the modification information on a given schema version.
func (*Meta) GetSchemaVersion ¶
GetSchemaVersion gets current global schema version.
func (*Meta) ListDatabases ¶
ListDatabases shows all databases.
func (*Meta) ListTables ¶
ListTables shows all tables in database.
func (*Meta) RemoveDDLReorgHandle ¶
RemoveDDLReorgHandle removes the job reorganization handle.
func (*Meta) SetSchemaDiff ¶
func (m *Meta) SetSchemaDiff(diff *model.SchemaDiff) error
SetSchemaDiff sets the modification information on a given schema version.
func (*Meta) UpdateDDLJob ¶
UpdateDDLJob updates the DDL job with index.
func (*Meta) UpdateDDLReorgHandle ¶
UpdateDDLReorgHandle saves the job reorganization latest processed handle for later resuming.
func (*Meta) UpdateDatabase ¶
UpdateDatabase updates a database with db info.
Source Files
Directories