v1workermeta

Documentation

Index

• func GetSubtasksMeta() (map[string]*pb.V1SubTaskMeta, error)
• func RemoveSubtasksMeta() error
• func SubTaskConfigFromV1TOML(data []byte) (config.SubTaskConfig, error)

Functions

func GetSubtasksMeta

func GetSubtasksMeta() (map[string]*pb.V1SubTaskMeta, error)

GetSubtasksMeta gets all subtasks' meta (config and status) from `dm_worker_meta` in v1.0.x.

func RemoveSubtasksMeta

func RemoveSubtasksMeta() error

RemoveSubtasksMeta removes subtasks' metadata. this is often called after upgraded from v1.0.x to v2.0.x, so no need to handle again after re-started the DM-worker process.

func SubTaskConfigFromV1TOML

func SubTaskConfigFromV1TOML(data []byte) (config.SubTaskConfig, error)

SubTaskConfigFromV1TOML gets SubTaskConfig from subtask's TOML data with v1.0.x.