migrate

Documentation

Index

• type Migrator
  • func NewMigrator(cli etcd.CDCEtcdClient, pdEndpoints []string, ...) Migrator
• type NoOpMigrator
  • func (f *NoOpMigrator) IsMigrateDone() bool
  • func (f *NoOpMigrator) MarkMigrateDone()
  • func (f *NoOpMigrator) Migrate(_ context.Context) error
  • func (f *NoOpMigrator) ShouldMigrate(_ context.Context) (bool, error)
  • func (f *NoOpMigrator) WaitMetaVersionMatched(_ context.Context) error

Types

type Migrator

type Migrator interface {
	// ShouldMigrate checks if we need to migrate metadata
	ShouldMigrate(ctx context.Context) (bool, error)
	// Migrate migrates the cdc metadata
	Migrate(ctx context.Context) error
	// WaitMetaVersionMatched wait util migration is done
	WaitMetaVersionMatched(ctx context.Context) error
	// MarkMigrateDone marks migration is done
	MarkMigrateDone()
	// IsMigrateDone check if migration is done
	IsMigrateDone() bool
}

Migrator migrates the cdc metadata

func NewMigrator

func NewMigrator(cli etcd.CDCEtcdClient,
	pdEndpoints []string,
	serverConfig *config.ServerConfig,
) Migrator

NewMigrator returns a cdc metadata

type NoOpMigrator

type NoOpMigrator struct{}

NoOpMigrator do nothing

func (*NoOpMigrator) IsMigrateDone

func (f *NoOpMigrator) IsMigrateDone() bool

IsMigrateDone check if migration is done

func (*NoOpMigrator) MarkMigrateDone

func (f *NoOpMigrator) MarkMigrateDone()

MarkMigrateDone marks migration is done

func (*NoOpMigrator) Migrate

func (f *NoOpMigrator) Migrate(_ context.Context) error

Migrate migrates the cdc metadata

func (*NoOpMigrator) ShouldMigrate

func (f *NoOpMigrator) ShouldMigrate(_ context.Context) (bool, error)

ShouldMigrate checks if we need to migrate metadata

func (*NoOpMigrator) WaitMetaVersionMatched

func (f *NoOpMigrator) WaitMetaVersionMatched(_ context.Context) error

WaitMetaVersionMatched wait util migration is done