utils

Documentation

Index

• func CreateDmCtl(addr string) (pb.MasterClient, error)
• func ExitWithError(err error)
• func OperateTask(ctx context.Context, cli pb.MasterClient, op pb.TaskOp, name string, ...) error
• func StartTask(ctx context.Context, cli pb.MasterClient, configFile string, workers []string) error

Functions

func CreateDmCtl

func CreateDmCtl(addr string) (pb.MasterClient, error)

CreateDmCtl creates a gRPC client to DM-master.

func ExitWithError

func ExitWithError(err error)

ExitWithError forces to exist the process, it's often used in integration tests.

func OperateTask

func OperateTask(ctx context.Context, cli pb.MasterClient, op pb.TaskOp, name string, workers []string) error

OperateTask does operations on the task.

func StartTask

func StartTask(ctx context.Context, cli pb.MasterClient, configFile string, workers []string) error

StartTask starts a task with the specified config.