jobs

Documentation

Overview

Package jobs implements persistence of the job definition. For the time being, only BoltDB persistence is implemented.

Index

• Variables
• func Migrate(ctx, fromCtx, toCtx context.Context, dryRun bool, ...) (map[string]int, error)
• func StripTaskData(task *jobs.Task)
• type DAO

Variables

var Drivers = service.StorageDrivers{}

var TasksLogsDirProvider = func() string {
	return rt.ApplicationWorkingDir(rt.ApplicationDirLogs)
}

Functions

func Migrate

func Migrate(ctx, fromCtx, toCtx context.Context, dryRun bool, status chan service.MigratorStatus) (map[string]int, error)

func StripTaskData

func StripTaskData(task *jobs.Task)

StripTaskData removes unnecessary data from the task log like fully loaded users, nodes, activities, etc.

Types

type DAO

type DAO interface {
	PutJob(job *jobs.Job) error
	GetJob(jobId string, withTasks jobs.TaskStatus) (*jobs.Job, error)
	DeleteJob(jobId string) error
	ListJobs(owner string, eventsOnly bool, timersOnly bool, withTasks jobs.TaskStatus, jobIDs []string, taskCursor ...int32) (chan *jobs.Job, error)

	PutTask(task *jobs.Task) error
	PutTasks(task map[string]map[string]*jobs.Task) error
	ListTasks(jobId string, taskStatus jobs.TaskStatus, cursor ...int32) (chan *jobs.Task, chan bool, error)
	DeleteTasks(jobId string, taskId []string) error

	FindOrphans() ([]*jobs.Task, error)
	BuildOrphanLogsQuery(time.Duration, []string) string
}

DAO provides method interface to access the store for scheduler job and task definitions.