job

Documentation

Index

• func PrintJobReport(jobReports []JobReport)
• type JobChain
• type JobContext
  • func NewJobContext() *JobContext
• type JobFunc
• type JobReport
• type JobStatus

Functions

func PrintJobReport

func PrintJobReport(jobReports []JobReport)

Types

type JobChain

type JobChain struct {
	JobName string
	JobFunc JobFunc
}

type JobContext

type JobContext struct {
	Ctx  context.Context
	Repo *repository.Repository
}

func NewJobContext

func NewJobContext() *JobContext

type JobFunc

type JobFunc func(ctx context.Context) (JobStatus, time.Time, int64, error)

type JobReport

type JobReport struct {
	JobName       string
	Status        JobStatus
	Error         error
	StartedTime   time.Time
	ExecutionTime int64
}

type JobStatus

type JobStatus string

const (
	JOB_PENDING         JobStatus = "PENDING"
	JOB_IN_PROGRESS     JobStatus = "IN PROGRESS"
	JOB_SUCCESS         JobStatus = "SUCCESS"
	JOB_FAILED          JobStatus = "FAILED"
	JOB_NOTHING_CHANGED JobStatus = "NOTHING CHANGED"
)