Function NewRestoreRegistry

br/pkg/registry/registration.go:213–239

NewRestoreRegistry creates a new registry using TiDB's session

(ctx context.Context, g glue.Glue, dom *domain.Domain)

// NewRestoreRegistry creates a new registry using TiDB's session
func NewRestoreRegistry(ctx context.Context, g glue.Glue, dom *domain.Domain) (*Registry, error) {
	se, err := g.CreateSession(dom.Store())
	if err != nil {
		return nil, errors.Trace(err)
	}
	heartbeatSession, err := g.CreateSession(dom.Store())
	if err != nil {
		return nil, errors.Trace(err)
	}
	tableExists := true
	_, err = dom.InfoSchema().TableByName(ctx,
		pmodel.NewCIStr(RestoreRegistryDBName),
		pmodel.NewCIStr(RestoreRegistryTableName),
	)
	if err != nil {
		if !infoschema.ErrTableNotExists.Equal(err) {
			return nil, errors.Trace(err)
		}
		tableExists = false
	}

	return &Registry{
		se:               se,
		heartbeatSession: heartbeatSession,
		tableExists:      tableExists,
	}, nil
}

func (r *Registry) Close() {
	log.Info("closing registry")