task

Documentation

Index

• type UpdateDMMeta
  • func NewUpdateDMMeta(cluster string, metadata *dmspec.Metadata, deletedNodesID []string) *UpdateDMMeta
  • func (u *UpdateDMMeta) Execute(ctx *task.Context) error
  • func (u *UpdateDMMeta) Rollback(ctx *task.Context) error
  • func (u *UpdateDMMeta) String() string

Types

type UpdateDMMeta

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

UpdateDMMeta is used to maintain the DM meta information

func NewUpdateDMMeta

func NewUpdateDMMeta(cluster string, metadata *dmspec.Metadata, deletedNodesID []string) *UpdateDMMeta

NewUpdateDMMeta create i update dm meta task.

func (*UpdateDMMeta) Execute

func (u *UpdateDMMeta) Execute(ctx *task.Context) error

Execute implements the Task interface

func (*UpdateDMMeta) Rollback

func (u *UpdateDMMeta) Rollback(ctx *task.Context) error

Rollback implements the Task interface

func (*UpdateDMMeta) String

func (u *UpdateDMMeta) String() string

String implements the fmt.Stringer interface