jobrunner

type MutLogger struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type TaskProgress struct {
	TaskID string

	TaskState TaskState

	// Used to cache the current task progress in resumes
	//
	// When resuming, set this to the current progress
	CurrentTaskProgress *taskstate.Progress

	// OnSetProgress is a callback that is called when SetProgress is called
	//
	// If unset, calls PersistTaskState
	OnSetProgress func(tc *TaskProgress, prog *taskstate.Progress) error
}

type TaskState struct {
	Ctx context.Context
}