migrate

Documentation

Index

• Constants
• Variables
• type Migrator
  • func New(stor *storage.Storage) *Migrator
  • func (m *Migrator) AddTask(ctx context.Context, task *storage.MigrationTask) error
  • func (m *Migrator) Load(ctx context.Context) error
  • func (m *Migrator) Shutdown()

Constants

const (
	SlotFailed  = "failed"
	SlotSuccess = "success"
)

const (
	TaskStatusSuccess = iota + 1
	TaskStatusFailed
)

Variables

var (
	ErrMismatchMigrateSlot   = errors.New("mismatched slot")
	ErrWrongSlotNode         = errors.New("the slot isn't belong to the node")
	ErrSlotFailed            = errors.New("migrate slot fail")
	ErrSlotCompleted         = errors.New("task has been completed")
	ErrAbortedMigrateRoutine = errors.New("aborted migrate routine")
	ErrGetClusterInfo        = errors.New("get cluster info failed")
)

Types

type Migrator

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

func New

func New(stor *storage.Storage) *Migrator

func (*Migrator) AddTask

func (m *Migrator) AddTask(ctx context.Context, task *storage.MigrationTask) error

func (*Migrator) Load

func (m *Migrator) Load(ctx context.Context) error

func (*Migrator) Shutdown

func (m *Migrator) Shutdown()