meta

Documentation

Index

• Variables
• type Meta
  • func NewMeta(txn kv.Transaction) *Meta
  • func (m *Meta) AddHistoryBgJob(job *model.Job) error
  • func (m *Meta) AddHistoryDDLJob(job *model.Job) error
  • func (m *Meta) BgJobQueueLen() (int64, 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) DeQueueBgJob() (*model.Job, error)
  • func (m *Meta) DeQueueDDLJob() (*model.Job, error)
  • func (m *Meta) DropDatabase(dbID int64) error
  • func (m *Meta) DropTable(dbID int64, tableID int64) error
  • func (m *Meta) EnQueueBgJob(job *model.Job) error
  • func (m *Meta) EnQueueDDLJob(job *model.Job) error
  • func (m *Meta) FinishBootstrap() 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) GetAutoTableID(dbID int64, tableID int64) (int64, error)
  • func (m *Meta) GetBgJob(index int64) (*model.Job, error)
  • func (m *Meta) GetBgJobOwner() (*model.Owner, error)
  • func (m *Meta) GetDDLJob(index int64) (*model.Job, error)
  • func (m *Meta) GetDDLJobOwner() (*model.Owner, 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) GetHistoryBgJob(id int64) (*model.Job, error)
  • func (m *Meta) GetHistoryDDLJob(id int64) (*model.Job, error)
  • func (m *Meta) GetSchemaVersion() (int64, error)
  • func (m *Meta) GetTable(dbID int64, tableID int64) (*model.TableInfo, error)
  • func (m *Meta) IsBootstrapped() (bool, 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) SetBgJobOwner(o *model.Owner) error
  • func (m *Meta) SetDDLJobOwner(o *model.Owner) error
  • func (m *Meta) UpdateBgJob(index int64, job *model.Job) 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

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")
)

Types

type Meta

type Meta struct {
	// contains filtered or unexported fields
}

Meta is for handling meta information in a transaction.

func NewMeta

func NewMeta(txn kv.Transaction) *Meta

NewMeta creates a Meta in transaction txn.

func (*Meta) AddHistoryBgJob

func (m *Meta) AddHistoryBgJob(job *model.Job) error

AddHistoryBgJob adds background job to history.

func (*Meta) AddHistoryDDLJob

func (m *Meta) AddHistoryDDLJob(job *model.Job) error

AddHistoryDDLJob adds DDL job to history.

func (*Meta) BgJobQueueLen

func (m *Meta) BgJobQueueLen() (int64, error)

BgJobQueueLen returns the background job queue length.

func (*Meta) CreateDatabase

func (m *Meta) CreateDatabase(dbInfo *model.DBInfo) error

CreateDatabase creates a database with db info.

func (*Meta) CreateTable

func (m *Meta) CreateTable(dbID int64, tableInfo *model.TableInfo) error

CreateTable creates a table with tableInfo in database.

func (*Meta) DDLJobQueueLen

func (m *Meta) DDLJobQueueLen() (int64, error)

DDLJobQueueLen returns the DDL job queue length.

func (*Meta) DeQueueBgJob

func (m *Meta) DeQueueBgJob() (*model.Job, error)

DeQueueBgJob pops a background job from the list.

func (*Meta) DeQueueDDLJob

func (m *Meta) DeQueueDDLJob() (*model.Job, error)

DeQueueDDLJob pops a DDL job from the list.

func (*Meta) DropDatabase

func (m *Meta) DropDatabase(dbID int64) error

DropDatabase drops whole database.

func (*Meta) DropTable

func (m *Meta) DropTable(dbID int64, tableID int64) error

DropTable drops table in database.

func (*Meta) EnQueueBgJob

func (m *Meta) EnQueueBgJob(job *model.Job) error

EnQueueBgJob adds a background job to the list.

func (*Meta) EnQueueDDLJob

func (m *Meta) EnQueueDDLJob(job *model.Job) error

EnQueueDDLJob adds a DDL job to the list.

func (*Meta) FinishBootstrap

func (m *Meta) FinishBootstrap() error

FinishBootstrap finishes bootstrap.

func (*Meta) GenAutoTableID

func (m *Meta) GenAutoTableID(dbID int64, tableID int64, step int64) (int64, error)

GenAutoTableID adds step to the auto id of the table and returns the sum.

func (*Meta) GenGlobalID

func (m *Meta) GenGlobalID() (int64, error)

GenGlobalID generates next id globally.

func (*Meta) GenSchemaVersion

func (m *Meta) GenSchemaVersion() (int64, error)

GenSchemaVersion generates next schema version.

func (*Meta) GetAutoTableID

func (m *Meta) GetAutoTableID(dbID int64, tableID int64) (int64, error)

GetAutoTableID gets current auto id with table id.

func (*Meta) GetBgJob

func (m *Meta) GetBgJob(index int64) (*model.Job, error)

GetBgJob returns the background job with index.

func (*Meta) GetBgJobOwner

func (m *Meta) GetBgJobOwner() (*model.Owner, error)

GetBgJobOwner gets the current background job owner.

func (*Meta) GetDDLJob

func (m *Meta) GetDDLJob(index int64) (*model.Job, error)

GetDDLJob returns the DDL job with index.

func (*Meta) GetDDLJobOwner

func (m *Meta) GetDDLJobOwner() (*model.Owner, error)

GetDDLJobOwner gets the current owner for DDL.

func (*Meta) GetDDLReorgHandle

func (m *Meta) GetDDLReorgHandle(job *model.Job) (int64, error)

GetDDLReorgHandle gets the latest processed handle.

func (*Meta) GetDatabase

func (m *Meta) GetDatabase(dbID int64) (*model.DBInfo, error)

GetDatabase gets the database value with ID.

func (*Meta) GetGlobalID

func (m *Meta) GetGlobalID() (int64, error)

GetGlobalID gets current global id.

func (*Meta) GetHistoryBgJob

func (m *Meta) GetHistoryBgJob(id int64) (*model.Job, error)

GetHistoryBgJob gets a history background job.

func (*Meta) GetHistoryDDLJob

func (m *Meta) GetHistoryDDLJob(id int64) (*model.Job, error)

GetHistoryDDLJob gets a history DDL job.

func (*Meta) GetSchemaVersion

func (m *Meta) GetSchemaVersion() (int64, error)

GetSchemaVersion gets current global schema version.

func (*Meta) GetTable

func (m *Meta) GetTable(dbID int64, tableID int64) (*model.TableInfo, error)

GetTable gets the table value in database with tableID.

func (*Meta) IsBootstrapped

func (m *Meta) IsBootstrapped() (bool, error)

IsBootstrapped returns whether we have already run bootstrap or not. return true means we don't need doing any other bootstrap.

func (*Meta) ListDatabases

func (m *Meta) ListDatabases() ([]*model.DBInfo, error)

ListDatabases shows all databases.

func (*Meta) ListTables

func (m *Meta) ListTables(dbID int64) ([]*model.TableInfo, error)

ListTables shows all tables in database.

func (*Meta) RemoveDDLReorgHandle

func (m *Meta) RemoveDDLReorgHandle(job *model.Job) error

RemoveDDLReorgHandle removes the job reorganization handle.

func (*Meta) SetBgJobOwner

func (m *Meta) SetBgJobOwner(o *model.Owner) error

SetBgJobOwner sets the current background job owner.

func (*Meta) SetDDLJobOwner

func (m *Meta) SetDDLJobOwner(o *model.Owner) error

SetDDLJobOwner sets the current owner for DDL.

func (*Meta) UpdateBgJob

func (m *Meta) UpdateBgJob(index int64, job *model.Job) error

UpdateBgJob updates the background job with index.

func (*Meta) UpdateDDLJob

func (m *Meta) UpdateDDLJob(index int64, job *model.Job) error

UpdateDDLJob updates the DDL job with index.

func (*Meta) UpdateDDLReorgHandle

func (m *Meta) UpdateDDLReorgHandle(job *model.Job, handle int64) error

UpdateDDLReorgHandle saves the job reorganization latest processed handle for later resuming.

func (*Meta) UpdateDatabase

func (m *Meta) UpdateDatabase(dbInfo *model.DBInfo) error

UpdateDatabase updates a database with db info.

func (*Meta) UpdateTable

func (m *Meta) UpdateTable(dbID int64, tableInfo *model.TableInfo) error

UpdateTable updates the table with table info.