disttaskutil

Documentation

Index

• func FindServerInfo(serverInfos []*infosync.ServerInfo, schedulerID string) int
• func GenerateExecID(info *infosync.ServerInfo) string
• func GenerateSubtaskExecID(ctx context.Context, id string) string
• func GenerateSubtaskExecID4Test(id string) string
• func MatchServerInfo(serverInfos []*infosync.ServerInfo, schedulerID string) bool

Functions

func FindServerInfo

func FindServerInfo(serverInfos []*infosync.ServerInfo, schedulerID string) int

FindServerInfo will find the schedulerID in all serverInfos.

func GenerateExecID

func GenerateExecID(info *infosync.ServerInfo) string

GenerateExecID used to generate IP:port as exec_id value This function is used by distributed task execution to generate serverID string to correlated one subtask to on TiDB node to be executed.

func GenerateSubtaskExecID

func GenerateSubtaskExecID(ctx context.Context, id string) string

GenerateSubtaskExecID generates the subTask execID.

func GenerateSubtaskExecID4Test

func GenerateSubtaskExecID4Test(id string) string

GenerateSubtaskExecID4Test generates the subTask execID, only used in unit tests.

func MatchServerInfo

func MatchServerInfo(serverInfos []*infosync.ServerInfo, schedulerID string) bool

MatchServerInfo will check if the schedulerID matched in all serverInfos.