tasks

Documentation

Index

• Constants
• func RunTask(task string, tokenSourceProvider impersonate.TargetPrincipalForProjectProvider, ...)
• type TaskRunner

Constants

const (
	// RunNewJobs is handled by task that start prepared jobs
	RunNewJobs = "run_new_jobs"
	// CheckJobsStatus is handled by task that update scheduled jobs status
	CheckJobsStatus = "check_jobs_status"
	// CheckOneShotBackupsStatus is handled by task that update jobs status for one shot backups
	CheckOneShotBackupsStatus = "check_backups_status"
	// CleanupExpiredSinks is handled by task that cleanup deleted backups or older files
	CleanupExpiredSinks = "cleanup_expired_sinks"
	// RescheduleJobsWithQuotaError is handled by task that start a new jobs that were interrupted due to quota exhaustion
	RescheduleJobsWithQuotaError = "reschedule_jobs_with_quota_error"
	// PrepareBackupJobs is handled by task that prepares new Jobs for scheduling
	PrepareBackupJobs = "prepare_backup_jobs"
	// CheckJobsStuck is handled by task that prepares check Jobs that are running to long
	CheckJobsStuck = "check_jobs_stuck"
	// CleanupExpiredJobs is handled by task that cleans up expired jobs
	CleanupExpiredJobs = "cleanup_expired_jobs"
)

Functions

func RunTask

func RunTask(task string, tokenSourceProvider impersonate.TargetPrincipalForProjectProvider, credentialsProvider secret.SecretProvider)

RunTask triggers specified task

Types

type TaskRunner

type TaskRunner interface {
	Run(context.Context)
}

TaskRunner runs tasks