restore

Documentation

Index

• func AssertUserDBsEmpty(dom *domain.Domain) error
• func GetTS(ctx context.Context, pdClient pd.Client) (uint64, error)
• func GetTSWithRetry(ctx context.Context, pdClient pd.Client) (uint64, error)
• func GetTableSchema(dom *domain.Domain, dbName pmodel.CIStr, tableName pmodel.CIStr) (*model.TableInfo, error)
• func RestorePostWork(ctx context.Context, switcher *ImportModeSwitcher, ...)
• func RestorePreWork(ctx context.Context, mgr *conn.Mgr, switcher *ImportModeSwitcher, ...) (pdutil.UndoFunc, *pdutil.ClusterConfig, error)
• func TransferBoolToValue(enable bool) string
• type Granularity
• type ImportModeSwitcher
  • func NewImportModeSwitcher(pdClient pd.Client, switchModeInterval time.Duration, tlsConf *tls.Config) *ImportModeSwitcher
• type UniqueTableName

Functions

func AssertUserDBsEmpty

func AssertUserDBsEmpty(dom *domain.Domain) error

AssertUserDBsEmpty check whether user dbs exist in the cluster

func GetTS

func GetTS(ctx context.Context, pdClient pd.Client) (uint64, error)

GetTS gets a new timestamp from PD.

func GetTSWithRetry

func GetTSWithRetry(ctx context.Context, pdClient pd.Client) (uint64, error)

GetTSWithRetry gets a new timestamp with retry from PD.

func GetTableSchema

func GetTableSchema(
	dom *domain.Domain,
	dbName pmodel.CIStr,
	tableName pmodel.CIStr,
) (*model.TableInfo, error)

GetTableSchema returns the schema of a table from TiDB.

func RestorePostWork

func RestorePostWork(
	ctx context.Context,
	switcher *ImportModeSwitcher,
	restoreSchedulers pdutil.UndoFunc,
	isOnline bool,
)

RestorePostWork executes some post work after restore. TODO: aggregate all lifetime manage methods into batcher's context manager field.

func RestorePreWork

func RestorePreWork(
	ctx context.Context,
	mgr *conn.Mgr,
	switcher *ImportModeSwitcher,
	isOnline bool,
	switchToImport bool,
) (pdutil.UndoFunc, *pdutil.ClusterConfig, error)

RestorePreWork executes some prepare work before restore. TODO make this function returns a restore post work.

func TransferBoolToValue

func TransferBoolToValue(enable bool) string

Types

type Granularity

type Granularity string

deprecated parameter

const (
	FineGrained   Granularity = "fine-grained"
	CoarseGrained Granularity = "coarse-grained"
)

type ImportModeSwitcher

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

func NewImportModeSwitcher

func NewImportModeSwitcher(
	pdClient pd.Client,
	switchModeInterval time.Duration,
	tlsConf *tls.Config,
) *ImportModeSwitcher

type UniqueTableName

type UniqueTableName struct {
	DB    string
	Table string
}