job

Documentation

Index

• func DoJobs(ctx context.Context)
• func PushJobChan(job *common.JobInfo)
• type DoingJobModel

Functions

func DoJobs

func DoJobs(ctx context.Context)

func PushJobChan

func PushJobChan(job *common.JobInfo)

Types

type DoingJobModel

type DoingJobModel struct {
	FlowId string
	JobId  string
	Cancel context.CancelFunc
}