v1workermeta

package
v0.0.0-...-19fc702 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 11, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL