task

Documentation

Index

• type UpdateDMMeta
  • func NewUpdateDMMeta(cluster string, metadata *dmspec.Metadata, deletedNodesID []string) *UpdateDMMeta
  • func (u *UpdateDMMeta) Execute(ctx context.Context) error
  • func (u *UpdateDMMeta) Rollback(ctx context.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 context.Context) error

Execute implements the Task interface the metadata especially the topology is in wide use, the other callers point to this field by a pointer, so we should update the original topology directly, and don't make a copy

func (*UpdateDMMeta) Rollback

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

Rollback implements the Task interface

func (*UpdateDMMeta) String

func (u *UpdateDMMeta) String() string

String implements the fmt.Stringer interface